Path	Lines of Code
flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/Iterations.java	434
flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java	151
flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java	107
flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java	539
flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java	191
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/DataStreamList.java	26
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationBody.java	31
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationBodyResult.java	32
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationConfig.java	28
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationID.java	9
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationListener.java	13
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationRecord.java	110
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/Iterations.java	434
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/ReplayableDataStreamList.java	40
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutput.java	6
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutputFactory.java	47
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java	21
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java	21
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/OutputReflectionContext.java	78
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/RecordWriterBroadcastOutput.java	33
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/checkpoint/Checkpoints.java	147
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/checkpoint/CheckpointsBroker.java	24
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java	176
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java	36
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java	37
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/KeyedBroadcastStateTransformationTranslator.java	42
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/KeyedMultipleInputTransformationTranslator.java	36
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/MultipleInputTransformationTranslator.java	30
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/OneInputTransformationTranslator.java	37
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/PartitionTransformationTranslator.java	24
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/ReduceTransformationTranslator.java	43
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/SideOutputTransformationTranslator.java	23
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/TwoInputTransformationTranslator.java	37
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/UnionTransformationTranslator.java	23
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/config/IterationOptions.java	14
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheReader.java	66
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java	209
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriter.java	120
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentReader.java	44
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentWriter.java	49
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/ListStateWithCache.java	119
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentReader.java	76
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java	126
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/Segment.java	69
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/SegmentReader.java	9
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/SegmentWriter.java	9
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java	22
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java	29
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/AbstractWrapperOperator.java	139
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java	471
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperatorCheckpointAligner.java	92
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperatorFactory.java	99
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/InputOperator.java	28
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OperatorStateUtils.java	17
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java	159
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OperatorWrapper.java	20
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OutputOperator.java	30
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java	230
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/TailOperator.java	88
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java	35
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java	220
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/AllRoundOperatorWrapper.java	74
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/EpochAware.java	7
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java	94
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/OneInputAllRoundWrapperOperator.java	66
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperator.java	88
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java	108
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java	249
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAlignerListener.java	7
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/CoordinatorCheckpointEvent.java	31
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/GloballyAlignedEvent.java	38
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/SubtaskAlignedEvent.java	52
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/TerminatingOnInitializeEvent.java	7
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorRecordProcessor.java	29
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorState.java	44
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/RegularHeadOperatorRecordProcessor.java	134
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/TerminatingHeadOperatorRecordProcessor.java	38
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java	547
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperator.java	134
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/OneInputPerRoundWrapperOperator.java	66
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java	74
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/TwoInputPerRoundWrapperOperator.java	109
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTracker.java	114
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerFactory.java	36
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerListener.java	5
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/ProxyKeySelector.java	16
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/ProxyOutput.java	73
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/ProxyStreamPartitioner.java	75
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyInternalTimeServiceManager.java	35
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java	191
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyOperatorStateBackend.java	122
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyStateSnapshotContext.java	27
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyStreamOperatorStateContext.java	87
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java	13
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializer.java	203
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordTypeInfo.java	65
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/utils/ReflectionUtils.java	90