Package | Description |
---|---|
org.apache.flink.iteration | |
org.apache.flink.ml.common.iteration |
Modifier and Type | Method and Description |
---|---|
void |
IterationListener.onEpochWatermarkIncremented(int epochWatermark,
IterationListener.Context context,
org.apache.flink.util.Collector<T> collector)
This callback is invoked every time the epoch watermark of this operator increments.
|
void |
IterationListener.onIterationTerminated(IterationListener.Context context,
org.apache.flink.util.Collector<T> collector)
This callback is invoked after the execution of the iteration body has terminated.
|
Modifier and Type | Method and Description |
---|---|
void |
TerminateOnMaxIter.onEpochWatermarkIncremented(int epochWatermark,
IterationListener.Context context,
org.apache.flink.util.Collector<Integer> out) |
void |
TerminateOnMaxIterOrTol.onEpochWatermarkIncremented(int epochWatermark,
IterationListener.Context context,
org.apache.flink.util.Collector<Integer> collector) |
void |
ForwardInputsOfLastRound.onEpochWatermarkIncremented(int epochWatermark,
IterationListener.Context context,
org.apache.flink.util.Collector<T> out) |
void |
TerminateOnMaxIter.onIterationTerminated(IterationListener.Context context,
org.apache.flink.util.Collector<Integer> collector) |
void |
TerminateOnMaxIterOrTol.onIterationTerminated(IterationListener.Context context,
org.apache.flink.util.Collector<Integer> collector) |
void |
ForwardInputsOfLastRound.onIterationTerminated(IterationListener.Context context,
org.apache.flink.util.Collector<T> out) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.