[jira] [Created] (FLINK-12081) Introduce aggregation operator code generator to blink batch

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12081) Introduce aggregation operator code generator to blink batch

Shang Yuanchun (Jira)
Jingsong Lee created FLINK-12081:
------------------------------------

             Summary: Introduce aggregation operator code generator to blink batch
                 Key: FLINK-12081
                 URL: https://issues.apache.org/jira/browse/FLINK-12081
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / Planner
            Reporter: Jingsong Lee
            Assignee: Jingsong Lee


1.Introduce aggregation code generator without keys.

2.Introduce sort aggregation code generator to deal with all aggregate functions with keys. (Require input in keys order.)

3.Introduce hash aggregation code generator to deal with DeclarativeAggregateFunction and aggregateBuffers can be update(e.g.: setInt) in BinaryRow. (Hash Aggregate performs much better than Sort Aggregate)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)