[
https://issues.apache.org/jira/browse/FLINK-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983221#comment-16983221
]
Jiayi Liao commented on FLINK-14950:
------------------------------------
[~SleePy] Thanks for your attention.
1. For example, I want to calculate the active users grouped by chatting room
(key). But I need to remove the window state when chatting room is closed which
comes from an online service (cannot make this online service a flink source).
So I'm going to register a processing timer in {{Trigger}} to check whether
chatting room is closed and register another processing timer if it's still
active.
2. I'm not sure this can be done in {{onProcessingTime}} function and even if
it works, it looks not elegant enough from my perspective.
Do you have other ways to help achieve this?
> Support getKey in WindowOperator.Context
> ----------------------------------------
>
> Key: FLINK-14950
> URL: https://issues.apache.org/jira/browse/FLINK-14950
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Affects Versions: 1.9.1
> Reporter: Jiayi Liao
> Priority: Major
>
> In our scenario, user needs to access the key of {{WindowOperator.Context}}
> to determine how to deal with the window.
> I think it's reasonable to support {{getKey()}} method in
> {{WindowOperator.Context}}.
> cc [~aljoscha]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
