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

Class WayangConvergenceCriterion<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Class create a ConvergenceCriterion that generate aggregatorWrapper

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
WayangConvergenceCriterion(FunctionDescriptor.SerializablePredicate<java.util.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 Detail

WayangConvergenceCriterion

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

Method Detail

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>