edu.snu.coral.runtime.executor.datatransfer

Class OutputWriter

java.lang.Object

edu.snu.coral.runtime.executor.datatransfer.DataTransfer

edu.snu.coral.runtime.executor.datatransfer.OutputWriter

All Implemented Interfaces:

AutoCloseable

public final class OutputWriter
extends DataTransfer
implements AutoCloseable

Represents the output data transfer from a task.

Constructor Summary

Constructors

Constructor and Description
OutputWriter(int hashRangeMultiplier, int srcTaskIdx, String srcRuntimeVertexId, IRVertex dstIrVertex, RuntimeEdge<?> runtimeEdge, BlockManagerWorker blockManagerWorker)

Method Summary

Modifier and Type	Method and Description
void	close() Notifies that all writes for a block is end.
void	write(Iterable dataToWrite) Writes output data depending on the communication pattern of the edge.

Methods inherited from class edu.snu.coral.runtime.executor.datatransfer.DataTransfer

getId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OutputWriter

public OutputWriter(int hashRangeMultiplier,
                    int srcTaskIdx,
                    String srcRuntimeVertexId,
                    @Nullable
                    IRVertex dstIrVertex,
                    RuntimeEdge<?> runtimeEdge,
                    BlockManagerWorker blockManagerWorker)

Method Detail

write

public void write(Iterable dataToWrite)

Writes output data depending on the communication pattern of the edge.

Parameters:

dataToWrite - An iterable for the elements to be written.

close

public void close()

Notifies that all writes for a block is end. Subscribers waiting for the data of the target block are notified when the block is committed. Also, further subscription about a committed block will not blocked but get the data in it and finished.

Specified by:

close in interface AutoCloseable