[jira] [Created] (FLINK-12133) Support unbounded aggregate in streaming table runtime

[Shang Yuanchun (Jira)]

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)