[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r738052142 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java ## @@ -0,0 +1,224 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r738052142 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java ## @@ -0,0 +1,224 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r738051805 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationRecord.java ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r738050835 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationRecord.java ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737984130 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/TailOperatorTest.java ## @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache S

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737983931 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/OutputOperatorTest.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737982214 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OutputOperator.java ## @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737981658 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/InputOperator.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-24645][iteration] Implements the feedback mechanism and the controller operators

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737981658 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/InputOperator.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Softw