org.apache.flink.statefun.flink.core.feedback

Class FeedbackChannelBroker

java.lang.Object

org.apache.flink.statefun.flink.core.feedback.FeedbackChannelBroker

public final class FeedbackChannelBroker
extends java.lang.Object

HandOffChannelBroker.

It is used together with the co-location constrain so that two tasks can access the same "hand-off" channel, and communicate directly (not via the network stack) by simply passing references in one direction.

To obtain a feedback channel one must first obtain an SubtaskFeedbackKey and simply call get(). A channel is removed from this broker on a call to FeedbackChannel.close().

Constructor Summary

Constructors

Constructor and Description
FeedbackChannelBroker()

Method Summary

Modifier and Type	Method and Description
static FeedbackChannelBroker	get()
<V> FeedbackChannel<V>	getChannel(SubtaskFeedbackKey<V> key)

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedbackChannelBroker

public FeedbackChannelBroker()

Method Detail

get

public static FeedbackChannelBroker get()

getChannel

public <V> FeedbackChannel<V> getChannel(SubtaskFeedbackKey<V> key)