flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3399) Count with timeout trigger
Date Thu, 25 Feb 2016 16:51:18 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167417#comment-15167417

ASF GitHub Bot commented on FLINK-3399:

Github user shikhar commented on the pull request:

    Thanks @StephanEwen, @aljoscha noted on the JIRA that it may be better to create a composable
mechanism like `Any.of(<count trigger>,<time trigger>)`
    Until that exists, I do think this is useful functionality, but let me know if we'd prefer
to just have the composable way and I should close this PR.

> 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

View raw message