[jira] [Created] (FLINK-13658) Combine two triggers into one (for streaming windows)

[Shang Yuanchun (Jira)]

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)