Class BulkIterationBase.TerminationCriterionAggregationConvergence
- java.lang.Object
-
- org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregationConvergence
-
- All Implemented Interfaces:
Serializable,ConvergenceCriterion<LongValue>
- Enclosing class:
- BulkIterationBase<T>
public static class BulkIterationBase.TerminationCriterionAggregationConvergence extends Object implements ConvergenceCriterion<LongValue>
Convergence for the termination criterion is reached if no tuple is output at current iteration for the termination criterion branch- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TerminationCriterionAggregationConvergence()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanisConverged(int iteration, LongValue countAggregate)Decide whether the iterative algorithm has converged
-
-
-
Method Detail
-
isConverged
public boolean isConverged(int iteration, LongValue countAggregate)Description copied from interface:ConvergenceCriterionDecide whether the iterative algorithm has converged- Specified by:
isConvergedin interfaceConvergenceCriterion<LongValue>
-
-