Package org.apache.nemo.runtime.executor.transfer

Responsible for transferring block content from one executor to another.

Interface Summary

Interface	Description
OutputContext	Represents the output context during the data transfer between two tasks.
TransferOutputStream	Represents the output stream to which the sender sends its data during the data transfer.

Class Summary

Class	Description
ByteInputContext	Container for multiple input streams.
ByteOutputContext	Container for multiple output streams.
ByteTransfer	Manages channels and exposes interface for BlockManagerWorker.
ByteTransferContext	ByteInputContext and ByteOutputContext.
ClosableBlockingQueue<T>	A blocking queue implementation which is capable of closing.
LocalInputContext	This class provides a data transfer interface to the receiver side when both the sender and the receiver are in the same executor.
LocalOutputContext	This class provides a data transfer interface to the sender side when both the sender and the receiver are in the same executor.
LocalTransferContext	This class represents the data transfer context when both the sender and the receiver are in the same executor.