You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jürgen Thomann (JIRA)" <ji...@apache.org> on 2018/02/05 12:41:00 UTC

[jira] [Created] (FLINK-8560) Access to the current key in ProcessFunction after keyBy()

Jürgen Thomann created FLINK-8560:
-------------------------------------

             Summary: Access to the current key in ProcessFunction after keyBy()
                 Key: FLINK-8560
                 URL: https://issues.apache.org/jira/browse/FLINK-8560
             Project: Flink
          Issue Type: Wish
          Components: DataStream API
            Reporter: Jürgen Thomann


Currently it is required to store the key of a keyBy() in the processElement method to have access to it in the OnTimerContext.

This is not so good as you have to check in the processElement method for every element if the key is already stored and set it if it's not already set.

A possible solution would adding OnTimerContext#getCurrentKey() or a similar method. Maybe having it in the open() method could maybe work as well.

http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Getting-Key-from-keyBy-in-ProcessFunction-tt18126.html



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)