public class BlockingBackChannel extends Object
Constructor and Description |
---|
BlockingBackChannel(SerializedUpdateBuffer buffer) |
Modifier and Type | Method and 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).
|
public BlockingBackChannel(SerializedUpdateBuffer buffer)
public DataInputView getReadEndAfterSuperstepEnded()
public DataOutputView getWriteEnd()
public void notifyOfEndOfSuperstep()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.