Uses of Class
org.apache.flink.api.java.operators.DeltaIteration
-
Packages that use DeltaIteration Package Description org.apache.flink.api.java org.apache.flink.api.java.operators -
-
Uses of DeltaIteration in org.apache.flink.api.java
Methods in org.apache.flink.api.java that return DeltaIteration Modifier and Type Method Description <R> DeltaIteration<T,R>DataSet. iterateDelta(DataSet<R> workset, int maxIterations, int... keyPositions)Deprecated.Initiates a delta iteration. -
Uses of DeltaIteration in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return DeltaIteration Modifier and Type Method Description DeltaIteration<ST,WT>DeltaIterationResultSet. getIterationHead()Deprecated.DeltaIteration<ST,WT>DeltaIteration. name(String name)Deprecated.Sets the name for the iteration.DeltaIteration<ST,WT>DeltaIteration. parallelism(int parallelism)Deprecated.Sets the parallelism for the iteration.<X extends org.apache.flink.types.Value>
DeltaIteration<ST,WT>DeltaIteration. registerAggregationConvergenceCriterion(String name, org.apache.flink.api.common.aggregators.Aggregator<X> aggregator, org.apache.flink.api.common.aggregators.ConvergenceCriterion<X> convergenceCheck)Deprecated.Registers anAggregatorfor the iteration together with aConvergenceCriterion.DeltaIteration<ST,WT>DeltaIteration. registerAggregator(String name, org.apache.flink.api.common.aggregators.Aggregator<?> aggregator)Deprecated.Registers anAggregatorfor the iteration.
-