Re: ReduceFunction mechanism

Posted by nragon on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ReduceFunction-mechanism-tp13651p13723.html

My goal is to touch each element before the aggregation but i could do it in the reduce function a not having to add another function, thus creating more overhead. The reduce method receives the reduced and a new element which i would change and apply my aggregation.
I'm doing keyby->reduce.
Using a map before all this is a solution.
I've  never tried AggregateFunction, any examples?

Thanks,
Nuno