[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14590727#comment-14590727
]
Alexander Alexandrov commented on FLINK-2237:
---------------------------------------------
In the Flink RT, operators are represented in the `PactDriver` family. I
suggest to proceed as follows
* read the code of an existing aggregate driver implementation (e.g. the
`GroupReduceCombineDriver`);
* use this as a starting point: create a copy of the class, and adapt it as a a
first sketch of your hash-based driver;
* implement a test for your driver (you can use the corresponding
`GroupReduceCombineDriver` test);
* push the sketch in a repository and summarize your attempt here.
We can then go over it and give you more concrete feedback.
> Add hash-based Aggregation
> --------------------------
>
> Key: FLINK-2237
> URL: https://issues.apache.org/jira/browse/FLINK-2237
> Project: Flink
> Issue Type: New Feature
> Reporter: Rafiullah Momand
> Priority: Minor
> Labels: github-import
> Fix For: pre-apache
>
>
> Aggregation functions at the moment are implemented in a sort-based way.
> How can we implement hash based Aggregation for Flink?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
