Uses of Package
org.apache.flink.runtime.iterative.concurrent
-
Packages that use org.apache.flink.runtime.iterative.concurrent Package Description org.apache.flink.runtime.iterative.concurrent org.apache.flink.runtime.iterative.task -
Classes in org.apache.flink.runtime.iterative.concurrent used by org.apache.flink.runtime.iterative.concurrent Class Description BlockingBackChannel A concurrent datastructure that establishes a backchannel buffer between an iteration head and an iteration tail.Broker A concurrent data structure that allows the hand-over of an object between a pair of threads.IterationAggregatorBroker SolutionSetUpdateBarrier Resettable barrier to synchronize theIterationHeadTaskand theIterationTailTaskin case of iterations that contain a separate solution set tail.SuperstepKickoffLatch Latch used to wait for the previous superstep to complete. -
Classes in org.apache.flink.runtime.iterative.concurrent used by org.apache.flink.runtime.iterative.task Class Description BlockingBackChannel A concurrent datastructure that establishes a backchannel buffer between an iteration head and an iteration tail.