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:54:18 GMT

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

ASF GitHub Bot commented on FLINK-3399:

Github user shikhar closed the pull request at:


> 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