[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
vishnu viswanath updated FLINK-6726: ------------------------------------ Description: 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. was: 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 it's state based on some condition. > Allow setting Timers in ProcessWindowFunction > --------------------------------------------- > > Key: FLINK-6726 > URL: https://issues.apache.org/jira/browse/FLINK-6726 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: vishnu viswanath > Assignee: vishnu viswanath > Priority: Minor > > 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 (v6.3.15#6346)