flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction
Date Fri, 11 Nov 2016 09:19:58 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15656596#comment-15656596
] 

ASF GitHub Bot commented on FLINK-5012:
---------------------------------------

Github user aljoscha commented on the issue:

    https://github.com/apache/flink/pull/2772
  
    Thanks for reviewing @jgrier!


> 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)

Mime
View raw message