graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordTypeInfo.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/KeyedMultipleInputTransformationTranslator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationRecord.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyStateSnapshotContext.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/event/GloballyAlignedEvent.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/MultipleInputTransformationTranslator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/UnionTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/OneInputTransformationTranslator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorState.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/SideOutputTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OperatorStateUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java]" -- "[flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linearsvc/LinearSVCModel.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/RecordWriterBroadcastOutput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/checkpoint/CheckpointsBroker.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyInternalTimeServiceManager.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/OneInputAllRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/OutputReflectionContext.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentWriter.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/TerminatingHeadOperatorRecordProcessor.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationID.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializer.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/ProxyKeySelector.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentReader.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/AbstractWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationBody.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyInternalTimeServiceManager.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/config/IterationOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-lib/src/main/java/org/apache/flink/ml/feature/polynomialexpansion/PolynomialExpansion.java]" -- "[flink-ml-lib/src/main/java/org/apache/flink/ml/feature/idf/IDFModel.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAlignerListener.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/ProxyOutput.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/KeyedMultipleInputTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/OutputOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/EpochAware.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/proxy/state/ProxyInternalTimeServiceManager.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/SegmentReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperatorFactory.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/broadcast/OutputReflectionContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/compile/translator/PartitionTransformationTranslator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationListener.java]" -- "[flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java]" -- "[flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }