Package org.apache.flink.api.common.operators.base

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

Modifier and Type	Method	Description
boolean	isConverged(int iteration, LongValue countAggregate)	Decide whether the iterative algorithm has converged

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TerminationCriterionAggregationConvergence

public TerminationCriterionAggregationConvergence()

Method Detail

isConverged

public boolean isConverged(int iteration,
                           LongValue countAggregate)

Description copied from interface: ConvergenceCriterion

Decide whether the iterative algorithm has converged

Specified by:

isConverged in interface ConvergenceCriterion<LongValue>