Shikhar Bhushan created FLINK-3399:
--------------------------------------
Summary: 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)
