return outputter.getOutputs(); | return outputter.getOutputs().iterator(); | outputter.getOutputs() | outputter.getOutputs().iterator() | beam | 95d92d4436d10751bcd59fc7f346741e6ea33a99 | org.apache.beam.runners.spark.translation.SparkGroupAlsoByWindowViaOutputBufferFn | | | | | | Returns | True |
return new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter); | return new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter).iterator(); | new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter) | new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter).iterator() | beam | 95d92d4436d10751bcd59fc7f346741e6ea33a99 | org.apache.beam.runners.spark.translation.MultiDoFnFunction | | | v0 | new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter) |
---|
| | v0 | new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter) |
---|
| Returns | True |
return CoderHelpers.fromByteArrays(serTimers,timerDataCoder); | return CoderHelpers.fromByteArrays(serTimers,timerDataCoder).iterator(); | CoderHelpers.fromByteArrays(serTimers,timerDataCoder) | CoderHelpers.fromByteArrays(serTimers,timerDataCoder).iterator() | beam | 95d92d4436d10751bcd59fc7f346741e6ea33a99 | org.apache.beam.runners.spark.stateful.SparkTimerInternals | | _1 | deserializeTimers |
---|
_2 | deserializeTimers |
---|
| v0 | CoderHelpers.fromByteArrays(serTimers,timerDataCoder) |
---|
| | v0 | CoderHelpers.fromByteArrays(serTimers,timerDataCoder) |
---|
| Returns | True |
return t2._1(); | return t2._1().iterator(); | t2._1() | t2._1().iterator() | beam | 95d92d4436d10751bcd59fc7f346741e6ea33a99 | org.apache.beam.runners.spark.io.SparkUnboundedSource.Tuple2byteFlatMapFunction | | | | | | Returns | True |
return Collections.singletonList(new Tuple2<>(0,0.0)); | return Collections.singletonList(new Tuple2<>(0,0.0)).iterator(); | Collections.singletonList(new Tuple2<>(0,0.0)) | Collections.singletonList(new Tuple2<>(0,0.0)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.multilayer.scoring.ScoreFlatMapFunctionAdapter | | | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| Returns | True |
return Collections.singletonList((T[])result); | return Collections.singletonList((T[])result).iterator(); | Collections.singletonList((T[])result) | Collections.singletonList((T[])result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.multilayer.evaluation.IEvaluateFlatMapFunctionAdapter | | | v0 | Collections.singletonList((T[])result) |
---|
| | v0 | Collections.singletonList((T[])result) |
---|
| Returns | True |
return Collections.singletonList(new Tuple2<>(0,0.0)); | return Collections.singletonList(new Tuple2<>(0,0.0)).iterator(); | Collections.singletonList(new Tuple2<>(0,0.0)) | Collections.singletonList(new Tuple2<>(0,0.0)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.graph.scoring.ScoreFlatMapFunctionCGMultiDataSetAdapter | | | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| Returns | True |
return Collections.singletonList(new Tuple2<>(0,0.0)); | return Collections.singletonList(new Tuple2<>(0,0.0)).iterator(); | Collections.singletonList(new Tuple2<>(0,0.0)) | Collections.singletonList(new Tuple2<>(0,0.0)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.graph.scoring.ScoreFlatMapFunctionCGDataSetAdapter | | | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| | v0 | Collections.singletonList(new Tuple2<>(0,0.0)) |
---|
| Returns | True |
return Collections.singletonList(result); | return Collections.singletonList(result).iterator(); | Collections.singletonList(result) | Collections.singletonList(result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.graph.evaluation.IEvaluateMDSPathsFlatMapFunctionAdapter | | | v0 | Collections.singletonList(result) |
---|
| | v0 | Collections.singletonList(result) |
---|
| Returns | True |
return Collections.singletonList((T[])result); | return Collections.singletonList((T[])result).iterator(); | Collections.singletonList((T[])result) | Collections.singletonList((T[])result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.impl.graph.evaluation.IEvaluateMDSFlatMapFunctionAdapter | | | v0 | Collections.singletonList((T[])result) |
---|
| | v0 | Collections.singletonList((T[])result) |
---|
| Returns | True |
return Collections.singletonList(worker.getFinalResult(net)); | return Collections.singletonList(worker.getFinalResult(net)).iterator(); | Collections.singletonList(worker.getFinalResult(net)) | Collections.singletonList(worker.getFinalResult(net)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter | | | v0 | Collections.singletonList(worker.getFinalResult(net)) |
---|
| | v0 | Collections.singletonList(worker.getFinalResult(net)) |
---|
| Returns | True |
return Collections.singletonList(pair.getFirst()); | return Collections.singletonList(pair.getFirst()).iterator(); | Collections.singletonList(pair.getFirst()) | Collections.singletonList(pair.getFirst()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter | | | v0 | Collections.singletonList(pair.getFirst()) |
---|
| | v0 | Collections.singletonList(pair.getFirst()) |
---|
| Returns | True |
return Collections.singletonList(result); | return Collections.singletonList(result).iterator(); | Collections.singletonList(result) | Collections.singletonList(result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter | | | v0 | Collections.singletonList(result) |
---|
| | v0 | Collections.singletonList(result) |
---|
| Returns | True |
return Collections.singletonList(result.getFirst()); | return Collections.singletonList(result.getFirst()).iterator(); | Collections.singletonList(result.getFirst()) | Collections.singletonList(result.getFirst()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter | | | v0 | Collections.singletonList(result.getFirst()) |
---|
| | v0 | Collections.singletonList(result.getFirst()) |
---|
| Returns | True |
return Collections.singletonList(worker.getFinalResult(net)); | return Collections.singletonList(worker.getFinalResult(net)).iterator(); | Collections.singletonList(worker.getFinalResult(net)) | Collections.singletonList(worker.getFinalResult(net)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(worker.getFinalResult(net)) |
---|
| | v0 | Collections.singletonList(worker.getFinalResult(net)) |
---|
| Returns | True |
return Collections.singletonList(worker.getFinalResult(graph)); | return Collections.singletonList(worker.getFinalResult(graph)).iterator(); | Collections.singletonList(worker.getFinalResult(graph)) | Collections.singletonList(worker.getFinalResult(graph)).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(worker.getFinalResult(graph)) |
---|
| | v0 | Collections.singletonList(worker.getFinalResult(graph)) |
---|
| Returns | True |
return Collections.singletonList(pair.getFirst()); | return Collections.singletonList(pair.getFirst()).iterator(); | Collections.singletonList(pair.getFirst()) | Collections.singletonList(pair.getFirst()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(pair.getFirst()) |
---|
| | v0 | Collections.singletonList(pair.getFirst()) |
---|
| Returns | True |
return Collections.singletonList(result); | return Collections.singletonList(result).iterator(); | Collections.singletonList(result) | Collections.singletonList(result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(result) |
---|
| | v0 | Collections.singletonList(result) |
---|
| Returns | True |
return Collections.singletonList(result.getFirst()); | return Collections.singletonList(result.getFirst()).iterator(); | Collections.singletonList(result.getFirst()) | Collections.singletonList(result.getFirst()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(result.getFirst()) |
---|
| | v0 | Collections.singletonList(result.getFirst()) |
---|
| Returns | True |
return Collections.singletonList(worker.getFinalResultNoData()); | return Collections.singletonList(worker.getFinalResultNoData()).iterator(); | Collections.singletonList(worker.getFinalResultNoData()) | Collections.singletonList(worker.getFinalResultNoData()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(worker.getFinalResultNoData()) |
---|
| | v0 | Collections.singletonList(worker.getFinalResultNoData()) |
---|
| Returns | True |
return Collections.singletonList(pair.getFirst()); | return Collections.singletonList(pair.getFirst()).iterator(); | Collections.singletonList(pair.getFirst()) | Collections.singletonList(pair.getFirst()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter | | | v0 | Collections.singletonList(pair.getFirst()) |
---|
| | v0 | Collections.singletonList(pair.getFirst()) |
---|
| Returns | True |
return Collections.singletonList((R)result); | return Collections.singletonList((R)result).iterator(); | Collections.singletonList((R)result) | Collections.singletonList((R)result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapPathsMDSAdapter | | | v0 | Collections.singletonList((R)result) |
---|
| | v0 | Collections.singletonList((R)result) |
---|
| Returns | True |
return Collections.singletonList((R)result); | return Collections.singletonList((R)result).iterator(); | Collections.singletonList((R)result) | Collections.singletonList((R)result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapPathsAdapter | | | v0 | Collections.singletonList((R)result) |
---|
| | v0 | Collections.singletonList((R)result) |
---|
| Returns | True |
return Collections.singletonList((R)result); | return Collections.singletonList((R)result).iterator(); | Collections.singletonList((R)result) | Collections.singletonList((R)result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapMultiDataSetAdapter | | | v0 | Collections.singletonList((R)result) |
---|
| | v0 | Collections.singletonList((R)result) |
---|
| Returns | True |
return Collections.singletonList((R)result); | return Collections.singletonList((R)result).iterator(); | Collections.singletonList((R)result) | Collections.singletonList((R)result).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapDataSetAdapter | | | v0 | Collections.singletonList((R)result) |
---|
| | v0 | Collections.singletonList((R)result) |
---|
| Returns | True |
return Collections.singletonList(newList); | return Collections.singletonList(newList).iterator(); | Collections.singletonList(newList) | Collections.singletonList(newList).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.datavec.spark.transform.transform.SparkTransformProcessFunctionAdapter | | | v0 | Collections.singletonList(newList) |
---|
| | v0 | Collections.singletonList(newList) |
---|
| Returns | True |
return Collections.singletonList(joinedValue.getValues()); | return Collections.singletonList(joinedValue.getValues()).iterator(); | Collections.singletonList(joinedValue.getValues()) | Collections.singletonList(joinedValue.getValues()).iterator() | deeplearning4j | dcc2baa6766fb5236a0afae7984c36cddcb80903 | org.datavec.spark.transform.join.FilterAndFlattenJoinedValuesAdapter | | | v0 | Collections.singletonList(joinedValue.getValues()) |
---|
| | v0 | Collections.singletonList(joinedValue.getValues()) |
---|
| Returns | True |