[
https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833223#comment-16833223
]
Hequn Cheng commented on FLINK-12401:
-------------------------------------
[~jark] Hi, great that you are also interested in this.
This jira is going to support emit incremental value either in Acc or
AccRetract. Whether Acc or AccRetract will be decided by the query.
As for local-global, I think you raised a good point. Similar to the normal
Aggregate, flatAggregate could also support local-global and miniBatch.
However, I planned to support these optimizations later.
What do you think?
> 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)
