[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r735132139 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/CountingBroadcastOutput.java ## @@ -0,0 +1,50 @@ +/* + * Licensed to th

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r735131924 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to th

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r735131743 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to th

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r730742537 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/broadcast/ChainingBroadcastOutput.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r720815462 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/broadcast/BroadcastOutputFactory.java ## @@ -0,0 +1,78 @@ +/* + * Licensed to

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

gaoyunhaii commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r720815419 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/broadcast/OutputReflectionContext.java ## @@ -0,0 +1,104 @@ +/* + * Licensed t