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

Interface BlockStream

All Known Implementing Classes:

BlockInputStream, BlockOutputStream

public interface BlockStream

BlockInputStream and BlockOutputStream.

Method Summary

Modifier and Type	Method and Description
String	getBlockId() Gets the block id.
Optional<DataStoreProperty.Value>	getBlockStore() Gets the block store type.
KeyRange	getKeyRange() Gets the key range.
String	getRemoteExecutorId() Gets the id of the remote executor.
String	getRuntimeEdgeId() Gets the runtime edge id.
boolean	isEncodePartialBlockEnabled() Gets whether the sender should start encoding even though the whole block has not been written yet.

Method Detail

getRemoteExecutorId

String getRemoteExecutorId()

Gets the id of the remote executor.

Returns:

the remote executor id

isEncodePartialBlockEnabled

boolean isEncodePartialBlockEnabled()

Gets whether the sender should start encoding even though the whole block has not been written yet.

Returns:

whether the sender should start encoding even though the whole block has not been written yet

getBlockStore

Optional<DataStoreProperty.Value> getBlockStore()

Gets the block store type.

Returns:

an Optional with block store type if this stream belongs to a pull-based transfer, an empty Optional otherwise.

getBlockId

String getBlockId()

Gets the block id.

Returns:

the block id

getRuntimeEdgeId

String getRuntimeEdgeId()

Gets the runtime edge id.

Returns:

the runtime edge id

getKeyRange

KeyRange getKeyRange()

Gets the key range.

Returns:

the KeyRange