org.apache.flink.streaming.runtime.io

Class BlockingQueueBroker

java.lang.Object

org.apache.flink.runtime.iterative.concurrent.Broker<BlockingQueue<?>>

org.apache.flink.streaming.runtime.io.BlockingQueueBroker

@Internal
public class BlockingQueueBroker
extends Broker<BlockingQueue<?>>

Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.

Field Summary

Fields

Modifier and Type	Field and Description
static BlockingQueueBroker	INSTANCE Singleton instance.

Method Summary

Methods inherited from class org.apache.flink.runtime.iterative.concurrent.Broker

get, getAndRemove, handIn, remove

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final BlockingQueueBroker INSTANCE

Singleton instance.