[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739933707 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/config/IterationOptions.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739747904 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/BoundedPerRoundStreamIterationITCase.java ## @@ -0,0 +1,159 @@ +/* + *

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739747861 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriteReadTest.java ## @@ -0,0 +1,181 @@ +/* + *

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739747819 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java ## @@ -176,6 +182,9 @@ public void

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739747754 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/PerRoundSubGraphBuilder.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r736240831 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/PerRoundSubGraphBuilder.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache