edu.snu.coral.runtime.executor.datatransfer

Class OutputCollectorImpl<O>

java.lang.Object

edu.snu.coral.runtime.executor.datatransfer.OutputCollectorImpl<O>

Type Parameters:

O - output type.

All Implemented Interfaces:

OutputCollector<O>, Serializable

public final class OutputCollectorImpl<O>
extends Object
implements OutputCollector<O>

Output Collector Implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OutputCollectorImpl() Constructor of a new OutputCollector.

Method Summary

Modifier and Type	Method and Description
List<O>	collectOutputList() Collects the accumulated output and replace the output list.
void	emit(O output) Single-destination emit.
void	emit(String dstVertexId, Object output) Multi-destination emit.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputCollectorImpl

public OutputCollectorImpl()

Constructor of a new OutputCollector.

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.

emit

public void emit(String dstVertexId,
                 Object 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>

Parameters:

dstVertexId - destination vertex id.

output - value.

collectOutputList

public List<O> collectOutputList()

Collects the accumulated output and replace the output list.

Returns:

the list of output elements.