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

Class RunTimeMessageOutputCollector<O>

java.lang.Object

org.apache.nemo.runtime.executor.datatransfer.RunTimeMessageOutputCollector<O>

Type Parameters:

O - output type.

All Implemented Interfaces:

java.io.Serializable, OutputCollector<O>

public final class RunTimeMessageOutputCollector<O>
extends java.lang.Object
implements OutputCollector<O>

OutputCollector for dynamic optimization data.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RunTimeMessageOutputCollector(java.lang.String taskId, IRVertex irVertex, PersistentConnectionToMasterMap connectionToMasterMap, TaskExecutor taskExecutor, boolean dataTransferNeeded)

Method Summary

Modifier and Type	Method	Description
<T> void	emit(java.lang.String dstVertexId, T output)	Multi-destination emit.
void	emit(O output)	Single-destination emit.
void	emitLatencymark(LatencyMark latencymark)	Emit latencymark to downstream vertices.
void	emitWatermark(Watermark watermark)	Emit watermark to downstream vertices.

Methods inherited from class java.lang.Object

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

Constructor Detail

RunTimeMessageOutputCollector

public RunTimeMessageOutputCollector(java.lang.String taskId,
                                     IRVertex irVertex,
                                     PersistentConnectionToMasterMap connectionToMasterMap,
                                     TaskExecutor taskExecutor,
                                     boolean dataTransferNeeded)

Method Detail

emit

public void emit(O output)

Description copied from interface: OutputCollector

Single-destination emit.

Specified by:

emit in interface OutputCollector<O>

Parameters:

output - value.

emitWatermark

public void emitWatermark(Watermark watermark)

Description copied from interface: OutputCollector

Emit watermark to downstream vertices.

Specified by:

emitWatermark in interface OutputCollector<O>

Parameters:

watermark - watermark

emitLatencymark

public void emitLatencymark(LatencyMark latencymark)

Description copied from interface: OutputCollector

Emit latencymark to downstream vertices.

Specified by:

emitLatencymark in interface OutputCollector<O>

Parameters:

latencymark - latencymark

emit

public <T> void emit(java.lang.String dstVertexId,
                     T output)

Description copied from interface: OutputCollector

Multi-destination emit. Currently unused, but might come in handy for operations like multi-output map.

Specified by:

emit in interface OutputCollector<O>

Type Parameters:

T - output type.

Parameters:

dstVertexId - destination vertex id.

output - value.