Sergei Winitzki created FLINK-13658:
---------------------------------------
Summary: 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
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)
