Like you said, it depends on the use case. The GroupReduceFunction is a generalization of the traditional reduce. Thus, it is more powerful. However, it is also executed differently; a GroupReduceFunction requires the whole group to be materialized and passed at once. If your program doesn't require that, use the normal reduce function.
On Thu, May 21, 2015 at 4:42 PM, santosh_rajaguru <sani...@gmail.com> wrote: > i am new to flink and map reduce. My query is > Apart from incrementally combing 2 elements, what are the merits of using > reduceFunction over GroupReduceFunction. which usecases suits what > functions > the most!!! > > > > > > > -- > View this message in context: > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/difference-between-reducefunction-and-GroupReduceFunction-tp5768.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com. >
