You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/01/08 12:17:00 UTC
[jira] [Closed] (FLINK-13658) Combine two triggers into one (for
streaming windows)
[ https://issues.apache.org/jira/browse/FLINK-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-13658.
------------------------------------
Resolution: Duplicate
This is a duplicate of the (very old) issue FLINK-4407. I'm not sure whether we still want to add the trigger DSL, to be honest, though.
> 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
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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
(v8.3.4#803005)