Package org.apache.flink.runtime.iterative.io
-
Class Summary Class Description HashPartitionIterator<BT,PT> Iterator
over the build side entries of aHashPartition
.SerializedUpdateBuffer AbstractPagedOutputView
used by theBlockingBackChannel
for transmitting superstep results.SolutionSetFastUpdateOutputCollector<T> ACollector
to update the solution set of a workset iteration.SolutionSetObjectsUpdateOutputCollector<T> ACollector
to update the solution set of a workset iteration.SolutionSetUpdateOutputCollector<T> ACollector
to update the solution set of a workset iteration.WorksetUpdateOutputCollector<T> ACollector
to update the iteration workset (partial solution for bulk iterations).