[
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)
