Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
The method on KeyedDataStream would be called process() and the function itself would be called ProcessFunction.
The reason for this is that TimelyFlatMapFunction is a bit of a mouthful and with the additions to the timer API and state the ProcessFunction could become the basic, low-level, user-facing API for cases where users nowadays implement their own operator.
Attachments
Issue Links
- depends upon
-
FLINK-4992 Expose String parameter for timers in Timely functions and TimerService
- Reopened
-
FLINK-5012 Provide Timestamp in TimelyFlatMapFunction
- Closed
- links to