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)