[ 
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592256#comment-14592256
 ] 

Stephan Ewen commented on FLINK-2237:
-------------------------------------

All of that being said, be aware of what you are implementing here: This may be 
one of the tougtest open issues in Flink. Since the performance of the hash 
aggregator pretty much defies the performance of the job, we really need to 
make every CPU cycle count in that implementation.

> 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)

Reply via email to