Uses of Class
org.apache.flink.runtime.iterative.concurrent.Broker

Packages that use Broker

Package	Description
org.apache.flink.runtime.iterative.concurrent
org.apache.flink.streaming.runtime.io

Uses of Broker in org.apache.flink.runtime.iterative.concurrent

Subclasses of Broker in org.apache.flink.runtime.iterative.concurrent

Modifier and Type	Class and Description
class	BlockingBackChannelBroker Singleton class for the threadsafe handover of BlockingBackChannels from iteration heads to iteration tails.
class	IterationAggregatorBroker Broker for RuntimeAggregatorRegistry.
class	SolutionSetBroker Used to hand over the hash-join from the iteration head to the solution-set match.
class	SolutionSetUpdateBarrierBroker Broker to hand over SolutionSetUpdateBarrier from IterationHeadTask to IterationTailTask.
class	SuperstepKickoffLatchBroker Broker for SuperstepKickoffLatch.

Methods in org.apache.flink.runtime.iterative.concurrent that return Broker

Modifier and Type	Method and Description
static Broker<SolutionSetUpdateBarrier>	SolutionSetUpdateBarrierBroker.instance()
static Broker<SuperstepKickoffLatch>	SuperstepKickoffLatchBroker.instance() Retrieve the singleton instance.
static Broker<BlockingBackChannel>	BlockingBackChannelBroker.instance() Retrieve singleton instance.
static Broker<Object>	SolutionSetBroker.instance() Retrieve the singleton instance.

Uses of Broker in org.apache.flink.streaming.runtime.io

Subclasses of Broker in org.apache.flink.streaming.runtime.io

Modifier and Type	Class and Description
class	BlockingQueueBroker Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.