flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction
Date Fri, 04 Nov 2016 09:51:58 GMT
Aljoscha Krettek created FLINK-5012:

             Summary: Provide Timestamp in TimelyFlatMapFunction
                 Key: FLINK-5012
                 URL: https://issues.apache.org/jira/browse/FLINK-5012
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Aljoscha Krettek

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

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.

This message was sent by Atlassian JIRA

View raw message