[jira] [Created] (FLINK-12794) Support ACC mode for non-window streaming FlatAggregate on Table API

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12794) Support ACC mode for non-window streaming FlatAggregate on Table API

Shang Yuanchun (Jira)
sunjincheng created FLINK-12794:
-----------------------------------

             Summary: Support ACC mode for non-window streaming FlatAggregate on Table API
                 Key: FLINK-12794
                 URL: https://issues.apache.org/jira/browse/FLINK-12794
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / API
    Affects Versions: 1.9.0
            Reporter: sunjincheng


Since the execution of the Stream operator has two modes, `ACC` and `ACCRetract`, users can achieve better performance by implementing special interfaces for streaming. The table below is a quick summary.
| |emitValue|emitUpdateWithRetract|emitUpdateWithoutRetract|
|ACC|Y|N|Y|
|ACCRetract|Y|Y|N|
 * emitValue - for batch and streaming.
 * eimitUpdateWithRetract - only for streaming in ACC mode(need key definition on TableAggregateFunction, [under discussion|https://docs.google.com/document/d/183qHo8PDG-xserDi_AbGP6YX9aPY0rVr80p3O3Gyz6U/edit?usp=sharing]).
 * emitUpdateWithoutRetract - only for streaming in ACCRetract mode.

 In this Jira we will add the ACC mode support for non-window streaming FlatAggregate. the detail can be found in [Flip-29|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97552739]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)