[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Konstantin Knauf updated FLINK-6726: ------------------------------------ Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (was: Minor) > Allow setting Timers in ProcessWindowFunction > --------------------------------------------- > > Key: FLINK-6726 > URL: https://issues.apache.org/jira/browse/FLINK-6726 > Project: Flink > Issue Type: Improvement > Components: API / DataStream > Reporter: Vishnu Viswanath > Assignee: Vishnu Viswanath > Priority: Not a Priority > Labels: stale-assigned > > Allow registration of timers in ProcessWindowFunction. > {code} > public abstract void registerEventTimeTimer(long time); > public abstract void registerProcessingTimeTimer(long time); > {code} > This is based on one of the use case that I have, where I need to register an > EventTimeTimer that will clean the elements in the Window State based on some > condition. -- This message was sent by Atlassian Jira (v8.3.4#803005)