Uses of Interface
org.apache.flink.api.common.aggregators.ConvergenceCriterion

Packages that use ConvergenceCriterion

Package	Description
org.apache.flink.api.common.aggregators
org.apache.flink.api.common.operators.base
org.apache.flink.api.java.operators
org.apache.flink.runtime.iterative.convergence
org.apache.flink.runtime.operators.util

Uses of ConvergenceCriterion in org.apache.flink.api.common.aggregators

Classes in org.apache.flink.api.common.aggregators that implement ConvergenceCriterion

Modifier and Type	Class and Description
class	DoubleZeroConvergence A ConvergenceCriterion over an Aggregator that defines convergence as reached once the aggregator holds the value zero.
class	LongZeroConvergence A ConvergenceCriterion over an Aggregator that defines convergence as reached once the aggregator holds the value zero.

Methods in org.apache.flink.api.common.aggregators that return ConvergenceCriterion

Modifier and Type	Method and Description
ConvergenceCriterion<?>	AggregatorRegistry.getConvergenceCriterion()

Methods in org.apache.flink.api.common.aggregators with parameters of type ConvergenceCriterion

Modifier and Type	Method and Description
<T extends Value> void	AggregatorRegistry.registerAggregationConvergenceCriterion(String name, Aggregator<T> aggregator, ConvergenceCriterion<T> convergenceCheck)

Uses of ConvergenceCriterion in org.apache.flink.api.common.operators.base

Classes in org.apache.flink.api.common.operators.base that implement ConvergenceCriterion

Modifier and Type	Class and Description
static class	BulkIterationBase.TerminationCriterionAggregationConvergence Convergence for the termination criterion is reached if no tuple is output at current iteration for the termination criterion branch

Uses of ConvergenceCriterion in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators with parameters of type ConvergenceCriterion

Modifier and Type	Method and Description
<X extends Value> DeltaIteration<ST,WT>	DeltaIteration.registerAggregationConvergenceCriterion(String name, Aggregator<X> aggregator, ConvergenceCriterion<X> convergenceCheck) Registers an Aggregator for the iteration together with a ConvergenceCriterion.
<X extends Value> IterativeDataSet<T>	IterativeDataSet.registerAggregationConvergenceCriterion(String name, Aggregator<X> aggregator, ConvergenceCriterion<X> convergenceCheck) Registers an Aggregator for the iteration together with a ConvergenceCriterion.

Uses of ConvergenceCriterion in org.apache.flink.runtime.iterative.convergence

Classes in org.apache.flink.runtime.iterative.convergence that implement ConvergenceCriterion

Modifier and Type	Class and Description
class	WorksetEmptyConvergenceCriterion A workset iteration is by definition converged if no records have been updated in the solutionset.

Uses of ConvergenceCriterion in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util that return ConvergenceCriterion

Modifier and Type	Method and Description
<T extends Value> ConvergenceCriterion<T>	TaskConfig.getConvergenceCriterion(ClassLoader cl)
<T extends Value> ConvergenceCriterion<T>	TaskConfig.getImplicitConvergenceCriterion(ClassLoader cl)

Methods in org.apache.flink.runtime.operators.util with parameters of type ConvergenceCriterion

Modifier and Type	Method and Description
void	TaskConfig.setConvergenceCriterion(String aggregatorName, ConvergenceCriterion<?> convCriterion)
void	TaskConfig.setImplicitConvergenceCriterion(String aggregatorName, ConvergenceCriterion<?> convCriterion) Sets the default convergence criterion of a DeltaIteration