[ https://issues.apache.org/jira/browse/FLINK-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-13658: ----------------------------------- Labels: pull-request-available (was: ) > Combine two triggers into one (for streaming windows) > ----------------------------------------------------- > > Key: FLINK-13658 > URL: https://issues.apache.org/jira/browse/FLINK-13658 > Project: Flink > Issue Type: New Feature > Components: API / DataStream > Reporter: Sergei Winitzki > Priority: Major > Labels: pull-request-available > > Combine two `Trigger`s into one. This allows users to write in one line a > windowed stream whose windows are defined by max element count together with > a max time delay between windows. > > Presently, Flink documentation and Stack Overflow discussions tell users to > implement such triggers manually as custom triggers. However, the > `TriggerResult` enumeration type can be defined as a monoid, and so two > results can be naturally combined into one. This allows users to combine two > or more triggers automatically. > > This implementation is a Scala-only prototype. I am new to Flink and may not > be able to contribute a fully compliant PR. -- This message was sent by Atlassian JIRA (v7.6.14#76016)