OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return outputter.getOutputs();return outputter.getOutputs().iterator();outputter.getOutputs()outputter.getOutputs().iterator()beam95d92d4436d10751bcd59fc7f346741e6ea33a99org.apache.beam.runners.spark.translation.SparkGroupAlsoByWindowViaOutputBufferFn
_173
_274
_1call
_2call
v0outputter.getOutputs()
v0outputter.getOutputs()
ReturnsTrue
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()beam95d92d4436d10751bcd59fc7f346741e6ea33a99org.apache.beam.runners.spark.translation.MultiDoFnFunction
_1103
_2103
_1call
_2call
v0new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter)
v0new SparkProcessContext<>(doFn,doFnRunnerWithMetrics,outputManager,stateful ? new TimerDataIterator(timerInternals) : Collections.<TimerInternals.TimerData>emptyIterator()).processPartition(iter)
ReturnsTrue
return CoderHelpers.fromByteArrays(serTimers,timerDataCoder);return CoderHelpers.fromByteArrays(serTimers,timerDataCoder).iterator();CoderHelpers.fromByteArrays(serTimers,timerDataCoder)CoderHelpers.fromByteArrays(serTimers,timerDataCoder).iterator()beam95d92d4436d10751bcd59fc7f346741e6ea33a99org.apache.beam.runners.spark.stateful.SparkTimerInternals
_1171
_2172
_1deserializeTimers
_2deserializeTimers
v0CoderHelpers.fromByteArrays(serTimers,timerDataCoder)
v0CoderHelpers.fromByteArrays(serTimers,timerDataCoder)
ReturnsTrue
return t2._1();return t2._1().iterator();t2._1()t2._1().iterator()beam95d92d4436d10751bcd59fc7f346741e6ea33a99org.apache.beam.runners.spark.io.SparkUnboundedSource.Tuple2byteFlatMapFunction
_1311
_2313
_1call
_2call
v0t2._1()
v0t2._1()
ReturnsTrue
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()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.multilayer.scoring.ScoreFlatMapFunctionAdapter
_162
_246
_1call
_2call
v0Collections.singletonList(new Tuple2<>(0,0.0))
v0Collections.singletonList(new Tuple2<>(0,0.0))
ReturnsTrue
return Collections.singletonList((T[])result);return Collections.singletonList((T[])result).iterator();Collections.singletonList((T[])result)Collections.singletonList((T[])result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.multilayer.evaluation.IEvaluateFlatMapFunctionAdapter
_183
_264
_1call
_2call
v0Collections.singletonList((T[])result)
v0Collections.singletonList((T[])result)
ReturnsTrue
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()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.graph.scoring.ScoreFlatMapFunctionCGMultiDataSetAdapter
_165
_252
_1call
_2call
v0Collections.singletonList(new Tuple2<>(0,0.0))
v0Collections.singletonList(new Tuple2<>(0,0.0))
ReturnsTrue
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()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.graph.scoring.ScoreFlatMapFunctionCGDataSetAdapter
_165
_252
_1call
_2call
v0Collections.singletonList(new Tuple2<>(0,0.0))
v0Collections.singletonList(new Tuple2<>(0,0.0))
ReturnsTrue
return Collections.singletonList(result);return Collections.singletonList(result).iterator();Collections.singletonList(result)Collections.singletonList(result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.graph.evaluation.IEvaluateMDSPathsFlatMapFunctionAdapter
_195
_275
_1call
_2call
v0Collections.singletonList(result)
v0Collections.singletonList(result)
ReturnsTrue
return Collections.singletonList((T[])result);return Collections.singletonList((T[])result).iterator();Collections.singletonList((T[])result)Collections.singletonList((T[])result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.impl.graph.evaluation.IEvaluateMDSFlatMapFunctionAdapter
_182
_261
_1call
_2call
v0Collections.singletonList((T[])result)
v0Collections.singletonList((T[])result)
ReturnsTrue
return Collections.singletonList(worker.getFinalResult(net));return Collections.singletonList(worker.getFinalResult(net)).iterator();Collections.singletonList(worker.getFinalResult(net))Collections.singletonList(worker.getFinalResult(net)).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter
_165
_247
_1call
_2call
v0Collections.singletonList(worker.getFinalResult(net))
v0Collections.singletonList(worker.getFinalResult(net))
ReturnsTrue
return Collections.singletonList(pair.getFirst());return Collections.singletonList(pair.getFirst()).iterator();Collections.singletonList(pair.getFirst())Collections.singletonList(pair.getFirst()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter
_165
_247
_1call
_2call
v0Collections.singletonList(pair.getFirst())
v0Collections.singletonList(pair.getFirst())
ReturnsTrue
return Collections.singletonList(result);return Collections.singletonList(result).iterator();Collections.singletonList(result)Collections.singletonList(result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter
_165
_247
_1call
_2call
v0Collections.singletonList(result)
v0Collections.singletonList(result)
ReturnsTrue
return Collections.singletonList(result.getFirst());return Collections.singletonList(result.getFirst()).iterator();Collections.singletonList(result.getFirst())Collections.singletonList(result.getFirst()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerMultiDataSetFlatMapAdapter
_165
_247
_1call
_2call
v0Collections.singletonList(result.getFirst())
v0Collections.singletonList(result.getFirst())
ReturnsTrue
return Collections.singletonList(worker.getFinalResult(net));return Collections.singletonList(worker.getFinalResult(net)).iterator();Collections.singletonList(worker.getFinalResult(net))Collections.singletonList(worker.getFinalResult(net)).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(worker.getFinalResult(net))
v0Collections.singletonList(worker.getFinalResult(net))
ReturnsTrue
return Collections.singletonList(worker.getFinalResult(graph));return Collections.singletonList(worker.getFinalResult(graph)).iterator();Collections.singletonList(worker.getFinalResult(graph))Collections.singletonList(worker.getFinalResult(graph)).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(worker.getFinalResult(graph))
v0Collections.singletonList(worker.getFinalResult(graph))
ReturnsTrue
return Collections.singletonList(pair.getFirst());return Collections.singletonList(pair.getFirst()).iterator();Collections.singletonList(pair.getFirst())Collections.singletonList(pair.getFirst()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(pair.getFirst())
v0Collections.singletonList(pair.getFirst())
ReturnsTrue
return Collections.singletonList(result);return Collections.singletonList(result).iterator();Collections.singletonList(result)Collections.singletonList(result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(result)
v0Collections.singletonList(result)
ReturnsTrue
return Collections.singletonList(result.getFirst());return Collections.singletonList(result.getFirst()).iterator();Collections.singletonList(result.getFirst())Collections.singletonList(result.getFirst()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(result.getFirst())
v0Collections.singletonList(result.getFirst())
ReturnsTrue
return Collections.singletonList(worker.getFinalResultNoData());return Collections.singletonList(worker.getFinalResultNoData()).iterator();Collections.singletonList(worker.getFinalResultNoData())Collections.singletonList(worker.getFinalResultNoData()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(worker.getFinalResultNoData())
v0Collections.singletonList(worker.getFinalResultNoData())
ReturnsTrue
return Collections.singletonList(pair.getFirst());return Collections.singletonList(pair.getFirst()).iterator();Collections.singletonList(pair.getFirst())Collections.singletonList(pair.getFirst()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.api.worker.ExecuteWorkerFlatMapAdapter
_166
_251
_1call
_2call
v0Collections.singletonList(pair.getFirst())
v0Collections.singletonList(pair.getFirst())
ReturnsTrue
return Collections.singletonList((R)result);return Collections.singletonList((R)result).iterator();Collections.singletonList((R)result)Collections.singletonList((R)result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapPathsMDSAdapter
_161
_252
_1call
_2call
v0Collections.singletonList((R)result)
v0Collections.singletonList((R)result)
ReturnsTrue
return Collections.singletonList((R)result);return Collections.singletonList((R)result).iterator();Collections.singletonList((R)result)Collections.singletonList((R)result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapPathsAdapter
_176
_268
_1call
_2call
v0Collections.singletonList((R)result)
v0Collections.singletonList((R)result)
ReturnsTrue
return Collections.singletonList((R)result);return Collections.singletonList((R)result).iterator();Collections.singletonList((R)result)Collections.singletonList((R)result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapMultiDataSetAdapter
_153
_242
_1call
_2call
v0Collections.singletonList((R)result)
v0Collections.singletonList((R)result)
ReturnsTrue
return Collections.singletonList((R)result);return Collections.singletonList((R)result).iterator();Collections.singletonList((R)result)Collections.singletonList((R)result).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.deeplearning4j.spark.parameterserver.functions.SharedFlatMapDataSetAdapter
_152
_243
_1call
_2call
v0Collections.singletonList((R)result)
v0Collections.singletonList((R)result)
ReturnsTrue
return Collections.singletonList(newList);return Collections.singletonList(newList).iterator();Collections.singletonList(newList)Collections.singletonList(newList).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.datavec.spark.transform.transform.SparkTransformProcessFunctionAdapter
_137
_238
_1call
_2call
v0Collections.singletonList(newList)
v0Collections.singletonList(newList)
ReturnsTrue
return Collections.singletonList(joinedValue.getValues());return Collections.singletonList(joinedValue.getValues()).iterator();Collections.singletonList(joinedValue.getValues())Collections.singletonList(joinedValue.getValues()).iterator()deeplearning4jdcc2baa6766fb5236a0afae7984c36cddcb80903org.datavec.spark.transform.join.FilterAndFlattenJoinedValuesAdapter
_141
_242
_1call
_2call
v0Collections.singletonList(joinedValue.getValues())
v0Collections.singletonList(joinedValue.getValues())
ReturnsTrue