Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
IterativeDataSet<T> |
DataSet.iterate(int maxIterations)
Initiates an iterative part of the program that executes multiple times and feeds back data
sets.
|
Modifier and Type | Method and Description |
---|---|
IterativeDataSet<T> |
BulkIterationResultSet.getIterationHead() |
<X extends Value> |
IterativeDataSet.registerAggregationConvergenceCriterion(String name,
Aggregator<X> aggregator,
ConvergenceCriterion<X> convergenceCheck)
Registers an
Aggregator for the iteration together with a ConvergenceCriterion . |
IterativeDataSet<T> |
IterativeDataSet.registerAggregator(String name,
Aggregator<?> aggregator)
Registers an
Aggregator for the iteration. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.