Interface | Description |
---|---|
AssignerWithPeriodicWatermarks<T> | Deprecated |
AssignerWithPunctuatedWatermarks<T> | Deprecated |
TimestampAssigner<T> | Deprecated |
Class | Description |
---|---|
AscendingTimestampExtractor<T> | Deprecated
Extend
AscendingTimestampExtractor instead. |
IngestionTimeExtractor<T> | Deprecated |
KeyedProcessFunction<K,I,O> |
A keyed function that processes elements of a stream.
|
ProcessFunction<I,O> |
A function that processes elements of a stream.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.