Package org.apache.wayang.flink.compiler.criterion

Class WayangConvergenceCriterion<T>

java.lang.Object

org.apache.wayang.flink.compiler.criterion.WayangConvergenceCriterion<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.aggregators.ConvergenceCriterion<WayangListValue>

public class WayangConvergenceCriterion<T>
extends Object
implements org.apache.flink.api.common.aggregators.ConvergenceCriterion<WayangListValue>, Serializable

Class create a that generate aggregatorWrapper

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
WayangConvergenceCriterion(FunctionDescriptor.SerializablePredicate<Collection<T>> predicate)

Method Summary

Modifier and Type	Method	Description
boolean	isConverged(int i, WayangListValue tWayangValue)
WayangConvergenceCriterion	setDoWhile(boolean doWhile)

Methods inherited from class java.lang.Object

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

Constructor Details

WayangConvergenceCriterion

public WayangConvergenceCriterion(FunctionDescriptor.SerializablePredicate<Collection<T>> predicate)

Method Details

setDoWhile

public WayangConvergenceCriterion setDoWhile(boolean doWhile)

isConverged

public boolean isConverged(int i,
 WayangListValue tWayangValue)

Specified by:

isConverged in interface org.apache.flink.api.common.aggregators.ConvergenceCriterion<T>