I added a comment with suggestions how to proceed in the JIRA issue. 2015-06-17 22:41 GMT+02:00 <rafi_33...@mailbox.tu-berlin.de>:
> > Hello dear Developer, > Currently aggregation functions are implemented based on sorting. We would > like to add hash based aggregation to Flink. We would be thankful if you > could tell as how to get started (shall we add it as an operator, runtime > or ...). Our current thinking is to first hash partition the data based on > grouping attribute and then apply aggregation function on the data that are > in same bucket. Now we need to know the work flow of Aggregation in Flink. > > With Respect, > Rafiullah Momand > >
