This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
from 0b6b7f70 [FLINK-32292] Fix TableUtils.getRowTypeInfo when the input
contains Tuple
add d38ce365 [FLINK-32285] Rename and copy flink-ml-iteration classes
add bb13b73f [FLINK-32285] Support multiple Flink versions in each Flink
ML Java library release
No new revisions were added by this update.
Summary of changes:
.github/workflows/java-tests.yml | 3 +-
docs/README.md | 6 +-
docs/content/docs/development/build-and-install.md | 11 +-
.../try-flink-ml/java/build-your-own-project.md | 2 +-
flink-ml-benchmark/pom.xml | 12 +-
flink-ml-core/pom.xml | 8 +-
flink-ml-dist/pom.xml | 8 +-
flink-ml-dist/src/main/assemblies/bin.xml | 6 +-
flink-ml-examples/pom.xml | 4 +-
.../{ => flink-ml-iteration-1.15}/pom.xml | 61 +++++++--
.../org/apache/flink/iteration/Iterations.java | 0
.../flink/iteration/operator/OperatorUtils.java | 55 ++++----
.../coordinator/HeadOperatorCoordinator.java | 31 +++--
.../perround/AbstractPerRoundWrapperOperator.java | 17 +--
.../proxy/state/ProxyKeyedStateBackend.java | 4 +-
.../coordinator/HeadOperatorCoordinatorTest.java | 9 +-
.../{ => flink-ml-iteration-1.16}/pom.xml | 61 +++++++--
.../{ => flink-ml-iteration-1.17}/pom.xml | 61 +++++++--
.../{ => flink-ml-iteration-common}/pom.xml | 21 ++-
.../org/apache/flink/iteration/DataStreamList.java | 0
.../org/apache/flink/iteration/IterationBody.java | 0
.../flink/iteration/IterationBodyResult.java | 0
.../apache/flink/iteration/IterationConfig.java | 0
.../org/apache/flink/iteration/IterationID.java | 0
.../apache/flink/iteration/IterationListener.java | 0
.../apache/flink/iteration/IterationRecord.java | 0
.../org/apache/flink/iteration/Iterations.java | 0
.../flink/iteration/ReplayableDataStreamList.java | 0
.../flink/iteration/broadcast/BroadcastOutput.java | 0
.../broadcast/BroadcastOutputFactory.java | 0
.../broadcast/ChainingBroadcastOutput.java | 0
.../broadcast/CountingBroadcastOutput.java | 0
.../broadcast/OutputReflectionContext.java | 0
.../broadcast/RecordWriterBroadcastOutput.java | 0
.../flink/iteration/checkpoint/Checkpoints.java | 0
.../iteration/checkpoint/CheckpointsBroker.java | 0
.../compile/DraftExecutionEnvironment.java | 0
.../compile/DraftTransformationTranslator.java | 0
.../BroadcastStateTransformationTranslator.java | 0
...eyedBroadcastStateTransformationTranslator.java | 0
...KeyedMultipleInputTransformationTranslator.java | 0
.../MultipleInputTransformationTranslator.java | 0
.../OneInputTransformationTranslator.java | 0
.../PartitionTransformationTranslator.java | 0
.../translator/ReduceTransformationTranslator.java | 0
.../SideOutputTransformationTranslator.java | 0
.../TwoInputTransformationTranslator.java | 0
.../translator/UnionTransformationTranslator.java | 0
.../flink/iteration/config/IterationOptions.java | 0
.../datacache/nonkeyed/DataCacheReader.java | 0
.../datacache/nonkeyed/DataCacheSnapshot.java | 0
.../datacache/nonkeyed/DataCacheWriter.java | 0
.../datacache/nonkeyed/FileSegmentReader.java | 0
.../datacache/nonkeyed/FileSegmentWriter.java | 0
.../datacache/nonkeyed/ListStateWithCache.java | 0
.../datacache/nonkeyed/MemorySegmentReader.java | 0
.../datacache/nonkeyed/MemorySegmentWriter.java | 0
.../iteration/datacache/nonkeyed/Segment.java | 0
.../datacache/nonkeyed/SegmentReader.java | 0
.../datacache/nonkeyed/SegmentWriter.java | 0
.../EpochAwareAllRoundProcessFunction.java | 0
.../functions/EpochAwareCoProcessFunction.java | 0
.../operator/AbstractWrapperOperator.java | 0
.../flink/iteration/operator/HeadOperator.java | 0
.../operator/HeadOperatorCheckpointAligner.java | 0
.../iteration/operator/HeadOperatorFactory.java | 0
.../flink/iteration/operator/InputOperator.java | 0
.../iteration/operator/OperatorStateUtils.java | 0
.../flink/iteration/operator/OperatorUtils.java | 0
.../flink/iteration/operator/OperatorWrapper.java | 0
.../flink/iteration/operator/OutputOperator.java | 0
.../flink/iteration/operator/ReplayOperator.java | 0
.../flink/iteration/operator/TailOperator.java | 0
.../iteration/operator/WrapperOperatorFactory.java | 0
.../allround/AbstractAllRoundWrapperOperator.java | 0
.../operator/allround/AllRoundOperatorWrapper.java | 0
.../iteration/operator/allround/EpochAware.java | 0
.../MultipleInputAllRoundWrapperOperator.java | 0
.../allround/OneInputAllRoundWrapperOperator.java | 0
.../allround/TwoInputAllRoundWrapperOperator.java | 0
.../coordinator/HeadOperatorCoordinator.java | 0
.../coordinator/SharedProgressAligner.java | 0
.../coordinator/SharedProgressAlignerListener.java | 0
.../operator/event/CoordinatorCheckpointEvent.java | 0
.../operator/event/GloballyAlignedEvent.java | 0
.../operator/event/SubtaskAlignedEvent.java | 0
.../event/TerminatingOnInitializeEvent.java | 0
.../headprocessor/HeadOperatorRecordProcessor.java | 0
.../operator/headprocessor/HeadOperatorState.java | 0
.../RegularHeadOperatorRecordProcessor.java | 0
.../TerminatingHeadOperatorRecordProcessor.java | 0
.../perround/AbstractPerRoundWrapperOperator.java | 0
.../MultipleInputPerRoundWrapperOperator.java | 0
.../perround/OneInputPerRoundWrapperOperator.java | 0
.../operator/perround/PerRoundOperatorWrapper.java | 0
.../perround/TwoInputPerRoundWrapperOperator.java | 0
.../OperatorEpochWatermarkTracker.java | 0
.../OperatorEpochWatermarkTrackerFactory.java | 0
.../OperatorEpochWatermarkTrackerListener.java | 0
.../flink/iteration/proxy/ProxyKeySelector.java | 0
.../apache/flink/iteration/proxy/ProxyOutput.java | 0
.../iteration/proxy/ProxyStreamPartitioner.java | 0
.../state/ProxyInternalTimeServiceManager.java | 0
.../proxy/state/ProxyKeyedStateBackend.java | 0
.../proxy/state/ProxyOperatorStateBackend.java | 0
.../proxy/state/ProxyStateSnapshotContext.java | 0
.../state/ProxyStreamOperatorStateContext.java | 0
.../iteration/proxy/state/StateNamePrefix.java | 0
.../typeinfo/IterationRecordSerializer.java | 0
.../typeinfo/IterationRecordTypeInfo.java | 0
.../flink/iteration/utils/ReflectionUtils.java | 0
.../flink/iteration/IterationConstructionTest.java | 0
.../iteration/broadcast/BroadcastOutputTest.java | 0
.../AllRoundDraftExecutionEnvironmentTest.java | 0
...DraftExecutionEnvironmentSwitchWrapperTest.java | 0
.../compile/DraftExecutionEnvironmentTestBase.java | 0
.../datacache/nonkeyed/DataCacheSnapshotTest.java | 0
.../datacache/nonkeyed/DataCacheWriteReadTest.java | 0
.../flink/iteration/operator/HeadOperatorTest.java | 0
.../iteration/operator/InputOperatorTest.java | 0
.../iteration/operator/OutputOperatorTest.java | 0
.../iteration/operator/ReplayOperatorTest.java | 0
.../flink/iteration/operator/TailOperatorTest.java | 0
.../iteration/operator/allround/LifeCycle.java | 0
.../MultipleInputAllRoundWrapperOperatorTest.java | 0
.../OneInputAllRoundWrapperOperatorTest.java | 0
.../TwoInputAllRoundWrapperOperatorTest.java | 0
.../coordinator/HeadOperatorCoordinatorTest.java | 0
.../coordinator/SharedProgressAlignerTest.java | 0
.../MultipleInputPerRoundWrapperOperatorTest.java | 0
.../OneInputPerRoundWrapperOperatorTest.java | 0
.../perround/PerRoundOperatorStateTest.java | 0
.../TwoInputPerRoundWrapperOperatorTest.java | 0
.../OperatorEpochWatermarkTrackerFactoryTest.java | 0
.../OperatorEpochWatermarkTrackerTest.java | 0
.../typeinfo/IterationRecordSerializerTest.java | 0
.../flink/iteration/utils/ReflectionUtilsTest.java | 0
.../src/test/resources/log4j2-test.properties | 0
flink-ml-iteration/pom.xml | 143 +--------------------
flink-ml-lib/pom.xml | 16 +--
flink-ml-python/dev/dev-requirements.txt | 2 +-
flink-ml-python/pom.xml | 4 +-
flink-ml-python/pyflink/ml/wrapper.py | 6 +-
flink-ml-python/setup.py | 2 +-
flink-ml-servable-core/pom.xml | 2 +-
flink-ml-servable-lib/pom.xml | 4 +-
flink-ml-tests/pom.xml | 6 +-
flink-ml-uber/pom.xml | 26 ++--
pom.xml | 29 ++++-
tools/ci/java_test_controller.sh | 11 +-
150 files changed, 316 insertions(+), 315 deletions(-)
copy flink-ml-iteration/{ => flink-ml-iteration-1.15}/pom.xml (75%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/main/java/org/apache/flink/iteration/Iterations.java
(100%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java
(82%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java
(90%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java
(97%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java
(99%)
copy flink-ml-iteration/{ =>
flink-ml-iteration-1.15}/src/test/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinatorTest.java
(96%)
copy flink-ml-iteration/{ => flink-ml-iteration-1.16}/pom.xml (75%)
copy flink-ml-iteration/{ => flink-ml-iteration-1.17}/pom.xml (75%)
copy flink-ml-iteration/{ => flink-ml-iteration-common}/pom.xml (93%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/DataStreamList.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationBody.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationBodyResult.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationConfig.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationID.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationListener.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/IterationRecord.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/Iterations.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/ReplayableDataStreamList.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutput.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/BroadcastOutputFactory.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/OutputReflectionContext.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/broadcast/RecordWriterBroadcastOutput.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/checkpoint/Checkpoints.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/checkpoint/CheckpointsBroker.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/BroadcastStateTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/KeyedBroadcastStateTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/KeyedMultipleInputTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/MultipleInputTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/OneInputTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/PartitionTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/ReduceTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/SideOutputTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/TwoInputTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/compile/translator/UnionTransformationTranslator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/config/IterationOptions.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheReader.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriter.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentReader.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/FileSegmentWriter.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/ListStateWithCache.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentReader.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/MemorySegmentWriter.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/Segment.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/SegmentReader.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/SegmentWriter.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/AbstractWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/HeadOperatorCheckpointAligner.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/HeadOperatorFactory.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/InputOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/OperatorStateUtils.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/OperatorWrapper.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/OutputOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/TailOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/WrapperOperatorFactory.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/AbstractAllRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/AllRoundOperatorWrapper.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/EpochAware.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/OneInputAllRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAlignerListener.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/event/CoordinatorCheckpointEvent.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/event/GloballyAlignedEvent.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/event/SubtaskAlignedEvent.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/event/TerminatingOnInitializeEvent.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorRecordProcessor.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/headprocessor/HeadOperatorState.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/headprocessor/RegularHeadOperatorRecordProcessor.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/headprocessor/TerminatingHeadOperatorRecordProcessor.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/perround/OneInputPerRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/operator/perround/TwoInputPerRoundWrapperOperator.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTracker.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerFactory.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerListener.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/ProxyKeySelector.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/ProxyOutput.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/ProxyStreamPartitioner.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyInternalTimeServiceManager.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyOperatorStateBackend.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyStateSnapshotContext.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/ProxyStreamOperatorStateContext.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializer.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordTypeInfo.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/main/java/org/apache/flink/iteration/utils/ReflectionUtils.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/IterationConstructionTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/broadcast/BroadcastOutputTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/compile/AllRoundDraftExecutionEnvironmentTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/compile/DraftExecutionEnvironmentSwitchWrapperTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/compile/DraftExecutionEnvironmentTestBase.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshotTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriteReadTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/HeadOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/InputOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/OutputOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/ReplayOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/TailOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/allround/LifeCycle.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/allround/OneInputAllRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAlignerTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/perround/OneInputPerRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorStateTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/operator/perround/TwoInputPerRoundWrapperOperatorTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerFactoryTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializerTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/java/org/apache/flink/iteration/utils/ReflectionUtilsTest.java
(100%)
rename flink-ml-iteration/{ =>
flink-ml-iteration-common}/src/test/resources/log4j2-test.properties (100%)
