Shaoxuan Wang created FLINK-6961:
------------------------------------
Summary: Enable configurable early-firing rate
Key: FLINK-6961
URL: https://issues.apache.org/jira/browse/FLINK-6961
Project: Flink
Issue Type: New Feature
Components: Table API & SQL
Reporter: Shaoxuan Wang
There are cases that we need to emit the result earlier to allow user get an
observation/sample of the result. Right now, only the unbounded aggregate works
in early-firing mode (in the future we will support early firing for all
different scenarios, like windowed aggregate, unbounded/windowed join, etc.).
But in unbounded aggregate, the result is prepared and emitted for each input.
This may not be necessary, as user may not need to get the result so frequent
in most cases.
We create this Jira to track all the efforts (sub-jira) to enable configurable
early-firing rate. It should be noted that the early-firing rate will not be
exposed to the user, it will be smartly decided by the query optimizer
depending on the SLA(allowed latency) of the final result.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
