Package org.apache.nemo.runtime.executor.datatransfer

Class PipeOutputWriter

java.lang.Object

org.apache.nemo.runtime.executor.datatransfer.PipeOutputWriter

All Implemented Interfaces:

OutputWriter

public final class PipeOutputWriter
extends java.lang.Object
implements OutputWriter

Represents the output data transfer from a task.

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.Optional<java.lang.Long>	getWrittenBytes()
void	write(java.lang.Object element)	Writes output element.
void	writeLatencymark(LatencyMark latencymark)	Writes latencymark to all edges.
void	writeWatermark(Watermark watermark)	Writes watermarks to all edges.

Methods inherited from class java.lang.Object

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

Method Detail

write

public void write(java.lang.Object element)

Writes output element.

Specified by:

write in interface OutputWriter

Parameters:

element - the element to write.

writeWatermark

public void writeWatermark(Watermark watermark)

Description copied from interface: OutputWriter

Writes watermarks to all edges.

Specified by:

writeWatermark in interface OutputWriter

Parameters:

watermark - watermark

writeLatencymark

public void writeLatencymark(LatencyMark latencymark)

Description copied from interface: OutputWriter

Writes latencymark to all edges. It does not consider buffered time in windows. transfer to the next task immediately.

Specified by:

writeLatencymark in interface OutputWriter

Parameters:

latencymark - latencymark

getWrittenBytes

public java.util.Optional<java.lang.Long> getWrittenBytes()

Specified by:

getWrittenBytes in interface OutputWriter

Returns:

the total written bytes.

close

public void close()

Specified by:

close in interface OutputWriter