Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Right now, TimelyFlatMapFunction does not give the timestamp of the element in flatMap().
The signature is currently this:
void flatMap(I value, TimerService timerService, Collector<O> out) throws Exception;
if we add the timestamp it would become this:
void flatMap(I value, Long timestamp, TimerService timerService, Collector<O> out) throws Exception;
The reason why it's a Long and not a long is that an element might not have a timestamp, in that case we should hand in null here.
This is becoming quite look so we could add a Context parameter that provides access to the timestamp and timer service.
Attachments
Issue Links
- is depended upon by
-
-
- Closed
-
- links to
