[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846681#comment-16846681 ]
Hequn Cheng commented on FLINK-12401: ------------------------------------- [~jark] Hi, incremental emit under AccRetract mode has been covered by [Flip-29|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97552739]. The `emitValueWithRetract` method will be used to emit incremental values(under AccRetract mode). There are also some examples in the doc. The `emitValueWithRetract` method will be used in preference to the `emitValue` method as it is considered to be more efficient. > Support incremental emit for non-window streaming FlatAggregate on Table API > ---------------------------------------------------------------------------- > > Key: FLINK-12401 > URL: https://issues.apache.org/jira/browse/FLINK-12401 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API > Reporter: Hequn Cheng > Assignee: Hequn Cheng > Priority: Major > > As described in > [Flip-29|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97552739], > there are two output modes for non-window streaming flatAggregate. One is > emitting with full values, the other is emitting with incremental values. > [FLINK-10977|https://issues.apache.org/jira/browse/FLINK-10977] supports the > former one, this jira is going to support the latter one. -- This message was sent by Atlassian JIRA (v7.6.3#76005)