You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Roey Shem Tov (Jira)" <ji...@apache.org> on 2020/04/08 20:38:00 UTC
[jira] [Created] (FLINK-17058) Adding TimeoutTrigger support nested
triggers
Roey Shem Tov created FLINK-17058:
-------------------------------------
Summary: Adding TimeoutTrigger support nested triggers
Key: FLINK-17058
URL: https://issues.apache.org/jira/browse/FLINK-17058
Project: Flink
Issue Type: Improvement
Components: API / DataSet
Reporter: Roey Shem Tov
Hello,
first Jira ticket that im opening here so if there is any mistakes of how doing it, please recorrect me.
My suggestion is to add a TimeoutTrigger that apply as nestedTrigger(as example how the PurgeTrigger does).
The TimeoutTrigger will support ProcessTime/EventTime and will have 2 timeous:
# Const timeout - when the first element of the window is arriving it is opening a timeout of X millis - after that the window will be evaluate.
# Continual timeout - each record arriving will increase the timeout of the evaluation of the window.
I found it very useful in our case when using flink, and i would like to work on it (if it is possible).
what do you think?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)