Yun Gao created FLINK-24808:
-------------------------------

             Summary: Support IterationListener for per-round operators
                 Key: FLINK-24808
                 URL: https://issues.apache.org/jira/browse/FLINK-24808
             Project: Flink
          Issue Type: Sub-task
          Components: Library / Machine Learning
    Affects Versions: 0.1.0
            Reporter: Yun Gao


We would need to also support IterationListener for the per-round operators. 
The difference between onEpochWatermarkIncremented and endInput for per-round 
operators are if it would be called at the last round (epoch = 
Integer.MAX_VALUE). This is necessary for some per-round operators that outputs 
final result.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to