Class BlockingBackChannel
- java.lang.Object
-
- org.apache.flink.runtime.iterative.concurrent.BlockingBackChannel
-
public class BlockingBackChannel extends Object
A concurrent datastructure that establishes a backchannel buffer between an iteration head and an iteration tail.
-
-
Constructor Summary
Constructors Constructor Description BlockingBackChannel(SerializedUpdateBuffer buffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DataInputView
getReadEndAfterSuperstepEnded()
Called by iteration head after it has sent all input for the current superstep through the data channel (blocks iteration head).DataOutputView
getWriteEnd()
Called by iteration tail to save the output of the current superstep.void
notifyOfEndOfSuperstep()
Called by iteration tail to signal that all input of a superstep has been processed (unblocks iteration head).
-
-
-
Constructor Detail
-
BlockingBackChannel
public BlockingBackChannel(SerializedUpdateBuffer buffer)
-
-
Method Detail
-
getReadEndAfterSuperstepEnded
public DataInputView getReadEndAfterSuperstepEnded()
Called by iteration head after it has sent all input for the current superstep through the data channel (blocks iteration head).
-
getWriteEnd
public DataOutputView getWriteEnd()
Called by iteration tail to save the output of the current superstep.
-
notifyOfEndOfSuperstep
public void notifyOfEndOfSuperstep()
Called by iteration tail to signal that all input of a superstep has been processed (unblocks iteration head).
-
-