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: {code} void flatMap(I value, TimerService timerService, Collector<O> out) throws Exception; {code} if we add the timestamp it would become this: {code} void flatMap(I value, Long timestamp, TimerService timerService, Collector<O> out) throws Exception; {code} 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 (v6.3.4#6332)