[
https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147052#comment-15147052
]
Aljoscha Krettek commented on FLINK-3399:
-----------------------------------------
Hi,
thanks for your interest and contribution. I think, however, that we need to
think about the windowing and triggers before making new additions. For
example, here I think that it would be beneficial to introduce compound
triggers instead of adding special case triggers for certain use cases. There
are already triggers for count and for time, so it would be good to have, for
example, an "Any" trigger that can be used like this: {{Any.of(<count
trigger>,<time trigger>)}} that would fire if any of the child triggers fire.
This will require some internal changes to work smoothly, however.
> Count with timeout trigger
> --------------------------
>
> Key: FLINK-3399
> URL: https://issues.apache.org/jira/browse/FLINK-3399
> Project: Flink
> Issue Type: Improvement
> Reporter: Shikhar Bhushan
> Priority: Minor
>
> I created an implementation of a trigger that I'd like to contribute,
> https://gist.github.com/shikhar/2cb9f1b792be31b7c16e
> An example application - if a sink function operates more efficiently if it
> is writing in a batched fashion, then the windowing mechanism + this trigger
> can be used. Count to have an upper bound on batch size & better control on
> memory usage, and timeout to ensure timeliness of the outputs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
