edu.snu.coral.common.ir

Interface OutputCollector<O>

Type Parameters:

O - output type.

All Superinterfaces:

Serializable

All Known Implementing Classes:

OutputCollectorImpl

public interface OutputCollector<O>
extends Serializable

Interface through which Transform emits outputs. This is to be implemented in the runtime with runtime-specific distributed data movement and storage mechanisms.

Method Summary

Modifier and Type	Method and Description
void	emit(O output) Single-destination emit.
void	emit(String dstVertexId, Object output) Multi-destination emit.

Method Detail

emit

void emit(O output)

Single-destination emit.

Parameters:

output - value.

emit

void emit(String dstVertexId,
          Object output)

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

Parameters:

dstVertexId - destination vertex id.

output - value.