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

gaoyunhaii commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739966230 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java ## @@ -0,0 +1,191 @@ +/* + * Licensed to the

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

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

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

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

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

gaoyunhaii commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739941592 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheReader.java ## @@ -0,0 +1,118 @@ +/* + * Licensed

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

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