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 -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651p13723.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
