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. |
ProcessFunction<I,O> |
A function that processes elements of a stream.
|
ProcessFunction.Context |
Information available in an invocation of
ProcessFunction.processElement(Object, Context, Collector)
or ProcessFunction.onTimer(long, OnTimerContext, Collector) . |
ProcessFunction.OnTimerContext |
Information available in an invocation of
ProcessFunction.onTimer(long, OnTimerContext, Collector) . |
TimestampAssigner<T> |
A
TimestampAssigner assigns event time timestamps to elements. |
TimestampExtractor<T> | Deprecated
This class has been replaced by
AssignerWithPeriodicWatermarks and
AssignerWithPunctuatedWatermarks |
Class | Description |
---|---|
AscendingTimestampExtractor<T> | Deprecated |
IngestionTimeExtractor<T> |
A timestamp assigner that assigns timestamps based on the machine's wall clock.
|
RichProcessFunction<I,O> |
Rich variant of the
ProcessFunction . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.