You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/04/27 13:11:04 UTC

[jira] [Closed] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context

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

Aljoscha Krettek closed FLINK-4953.
-----------------------------------
       Resolution: Fixed
    Fix Version/s: 1.3.0

Implemented in db759c5303bef8b412a183b4bcdf6d11abb7f327

> Allow access to "time" in ProcessWindowFunction.Context
> -------------------------------------------------------
>
>                 Key: FLINK-4953
>                 URL: https://issues.apache.org/jira/browse/FLINK-4953
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API
>            Reporter: Manu Zhang
>            Assignee: Manu Zhang
>             Fix For: 1.3.0
>
>
> The recently added {{ProcessWindowFunction}} has a {{Context}} object that allows querying some additional information about the window firing that we are processing. Right now, this is only the window for which the firing is happening. We should extends this with methods that allow querying the current processing time and the current watermark.
> Original text by issue creator: This is similar to FLINK-3674 but exposing time information in window functions. Currently when a timer is fired, all states in a window will be returned to users, including those after the timer. This change will allow users to filter out states after the timer based on time info.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)