Class DeltaIteration.WorksetPlaceHolder<WT>
- java.lang.Object
-
- org.apache.flink.api.java.DataSet<WT>
-
- org.apache.flink.api.java.operators.DeltaIteration.WorksetPlaceHolder<WT>
-
- Type Parameters:
WT- The data type of the elements in the workset.
- Enclosing class:
- DeltaIteration<ST,WT>
@Public public static class DeltaIteration.WorksetPlaceHolder<WT> extends DataSet<WT>
ADataSetthat acts as a placeholder for the workset during the iteration.
-
-
Method Summary
-
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
-
-