OutputCollector (Nemo Project 0.4 API)

Type Parameters:

O - output type.

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

DataFetcherOutputCollector, GBKTransform.GBKOutputCollector, OperatorVertexOutputCollector, OperatorWatermarkCollector, RunTimeMessageOutputCollector
```
public interface OutputCollector<O>
extends java.io.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

All Methods Instance Methods Abstract Methods
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.

- Method Detail
  - emit
```
void emit(O output)
```
    Single-destination emit.
    
    Parameters:
    
    output - value.
  - emitWatermark
```
void emitWatermark(Watermark watermark)
```
    Emit watermark to downstream vertices.
    
    Parameters:
    
    watermark - watermark
  - emitLatencymark
```
void emitLatencymark(LatencyMark latencymark)
```
    Emit latencymark to downstream vertices.
    
    Parameters:
    
    latencymark - latencymark
  - emit
```
<T> void emit(java.lang.String dstVertexId,
              T output)
```
    Multi-destination emit. Currently unused, but might come in handy for operations like multi-output map.
    
    Type Parameters:
    
    T - output type.
    
    Parameters:
    
    dstVertexId - destination vertex id.
    
    output - value.