gaoyunhaii commented on a change in pull request #17:
URL: https://github.com/apache/flink-ml/pull/17#discussion_r731782006
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/coordinator/HeadOperatorCoordinator.java
##
@@ -63,10 +63,16 @@
gaoyunhaii commented on a change in pull request #17:
URL: https://github.com/apache/flink-ml/pull/17#discussion_r731780041
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/HeadOperator.java
##
@@ -129,12 +168,89 @@ public void setup(
gaoyunhaii commented on a change in pull request #17:
URL: https://github.com/apache/flink-ml/pull/17#discussion_r731534576
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/HeadOperator.java
##
@@ -129,12 +168,89 @@ public void setup(