Package org.apache.flink.streaming.runtime.operators

This package contains the operators that perform the stream transformations. One or more operators are bundled into a "chain" and executed in a stream task.

Class Summary

Class	Description
CheckpointCommitter	This class is used to save information about which sink operator instance has committed checkpoints to a backend.
GenericWriteAheadSink<IN>	Generic Sink that emits its input elements into an arbitrary backend.
TimestampsAndWatermarksOperator<T>	A stream operator that may do one or both of the following: extract timestamps from events and generate watermarks.
TimestampsAndWatermarksOperator.WatermarkEmitter	Implementation of the WatermarkEmitter, based on the components that are available inside a stream operator.
TimestampsAndWatermarksOperatorFactory<T>	StreamOperatorFactory for TimestampsAndWatermarksOperator.