Package org.apache.flink.api.java.operators

Class BulkIterationResultSet<T>

java.lang.Object

org.apache.flink.api.java.DataSet<T>

org.apache.flink.api.java.operators.BulkIterationResultSet<T>

Type Parameters:

T -

@Internal
public class BulkIterationResultSet<T>
extends DataSet<T>

Resulting DataSet of bulk iterations.

Field Summary

Fields inherited from class org.apache.flink.api.java.DataSet

context

Method Summary

Modifier and Type	Method	Description
IterativeDataSet<T>	getIterationHead()
DataSet<T>	getNextPartialSolution()
DataSet<?>	getTerminationCriterion()

Methods inherited from class org.apache.flink.api.java.DataSet

aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText

Methods inherited from class java.lang.Object

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

Method Detail

getIterationHead

public IterativeDataSet<T> getIterationHead()

getNextPartialSolution

public DataSet<T> getNextPartialSolution()

getTerminationCriterion

public DataSet<?> getTerminationCriterion()