[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-5768:
---------------------------------
Description:
Apply new aggregation functions for datastream and dataset tables
This includes:
1. Change the implementation of the DataStream aggregation runtime code to use
new aggregation functions and aggregate dataStream API.
2. DataStream will be always running in incremental mode, as explained in
06/Feb/2017 in FLINK5564.
2. Change the implementation of the Dataset aggregation runtime code to use new
aggregation functions.
3. Clean up unused class and method.
was:Change the implementation of the DataStream aggregation runtime code to
use new aggregation functions and aggregate dataStream API.
> Apply new aggregation functions for datastream and dataset tables
> -----------------------------------------------------------------
>
> Key: FLINK-5768
> URL: https://issues.apache.org/jira/browse/FLINK-5768
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Shaoxuan Wang
> Assignee: Shaoxuan Wang
>
> Apply new aggregation functions for datastream and dataset tables
> This includes:
> 1. Change the implementation of the DataStream aggregation runtime code to
> use new aggregation functions and aggregate dataStream API.
> 2. DataStream will be always running in incremental mode, as explained in
> 06/Feb/2017 in FLINK5564.
> 2. Change the implementation of the Dataset aggregation runtime code to use
> new aggregation functions.
> 3. Clean up unused class and method.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
