Re: ReduceFunction mechanism

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ReduceFunction-mechanism-tp13651p13722.html

You can use a MapFunction (however, it will touch each element and not only the first).
An alternative could be the AggregateFunction if you are using ReduceFunction on a WindowedStream. The interface is a bit more complex though.

Best, Fabian

2017-06-13 10:55 GMT+02:00 nragon <[hidden email]>:

So, if my reduce function applies some transformation I must migrate that
transformation to a map before the reduce to ensure it transforms, even if
there is only one element?
I can chain them together and it will be "almost" as they were in the same
function(Ensure same thread processing)?



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ReduceFunction-mechanism-tp13651p13679.html

Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.