public final class FeedbackChannelBroker extends java.lang.Object
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
get(). A channel is removed from this broker on a call to
|Constructor and Description|
|Modifier and Type||Method and Description|
public static FeedbackChannelBroker get()
public <V> FeedbackChannel<V> getChannel(SubtaskFeedbackKey<V> key)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.