Jark Wu created FLINK-12133:
-------------------------------
Summary: Support unbounded aggregate in streaming table runtime
Key: FLINK-12133
URL: https://issues.apache.org/jira/browse/FLINK-12133
Project: Flink
Issue Type: New Feature
Components: Table SQL / Runtime
Reporter: Jark Wu
Assignee: Jark Wu
This ticket is aiming to support unbounded aggregate in streaming runtime. This
should includes:
1. GroupAggFunction: function that support unbounded aggregate without
optimizations
2. MiniBatchGroupAggFunction: function that support unbounded aggregate with
minibatch optimization
3. MiniBatchLocalGroupAggFunction & MiniBatchGlobalGroupAggFunction: function
that support unbounded aggregate with local combine optimization
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
