org.apache.flink.runtime.iterative.concurrent

Class Broker<V>

java.lang.Object

org.apache.flink.runtime.iterative.concurrent.Broker<V>

Direct Known Subclasses:

BlockingBackChannelBroker, BlockingQueueBroker, IterationAggregatorBroker, SolutionSetBroker, SolutionSetUpdateBarrierBroker, SuperstepKickoffLatchBroker

public class Broker<V>
extends Object

A concurrent data structure that allows the hand-over of an object between a pair of threads

Constructor Summary

Constructors

Constructor and Description
Broker()

Method Summary

Modifier and Type	Method and Description
V	get(String key) blocking retrieval and removal of the object to share
V	getAndRemove(String key) blocking retrieval and removal of the object to share
void	handIn(String key, V obj) hand in the object to share
void	remove(String key) blocking retrieval and removal of the object to share

Methods inherited from class java.lang.Object

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

Constructor Detail

Broker

public Broker()

Method Detail

handIn

public void handIn(String key,
                   V obj)

hand in the object to share

getAndRemove

public V getAndRemove(String key)

blocking retrieval and removal of the object to share

remove

public void remove(String key)

blocking retrieval and removal of the object to share

get

public V get(String key)

blocking retrieval and removal of the object to share