flink-issues mailing list archives

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

     [ https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Aljoscha Krettek reassigned FLINK-5012:

    Assignee: Aljoscha Krettek

> 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
>            Assignee: 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

View raw message