Package org.apache.flink.streaming.api.functions

Interface Summary

Interface	Description
AssignerWithPeriodicWatermarks<T>	The AssignerWithPeriodicWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
AssignerWithPunctuatedWatermarks<T>	The AssignerWithPunctuatedWatermarks assigns event time timestamps to elements, and generates low watermarks that signal event time progress within the stream.
TimestampAssigner<T>	A TimestampAssigner assigns event time timestamps to elements.
TimestampExtractor<T>	Deprecated This class has been replaced by AssignerWithPeriodicWatermarks and AssignerWithPunctuatedWatermarks

Class Summary

Class	Description
AscendingTimestampExtractor<T>	Deprecated Extend AscendingTimestampExtractor instead.
IngestionTimeExtractor<T>	A timestamp assigner that assigns timestamps based on the machine's wall clock.
ProcessFunction<I,O>	A function that processes elements of a stream.