Package edu.snu.coral.runtime.executor.data.blocktransfer

Responsible for transferring block content from one executor to another.

See: Description

Interface Summary

Interface	Description
BlockStream	BlockInputStream and BlockOutputStream.

Class Summary

Class	Description
BlockInputStream<T>	Input stream for block transfer.
BlockOutputStream<T>	Output stream for block transfer.
BlockTransfer	Manages channels and exposes an interface for BlockManagerWorker.
ClosableBlockingQueue<T>	A blocking queue implementation which is capable of closing the input end.

Package edu.snu.coral.runtime.executor.data.blocktransfer Description

Responsible for transferring block content from one executor to another.