Package org.apache.flink.datastream.impl.common

Class Summary

Class	Description
KeyCheckedOutputCollector<KEY,OUT>	This output checks whether the current key of the output record and the key extracted with a specific key selector are exactly the same.
OutputCollector<OUT>	The default implementation of Collector.
TimestampCollector<OUT>	The base Collector which take care of records timestamp.