Package org.apache.flink.runtime.operators.shipping

Class Summary

Class	Description
OutputCollector<T>	The OutputCollector collects records, and emits them to the RecordWriters.
OutputEmitter<T>	The output emitter decides to which of the possibly multiple output channels a record is sent.

Enum Summary

Enum	Description
ShipStrategyType	Enumeration defining the different shipping types of the output, such as local forward, re-partitioning by hash, or re-partitioning by range.