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 <nuno.goncal...@wedotechnologies.com>: > 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. >
