Re: ReduceFunction mechanism

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

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)?