No, the reduce() method of a ReduceFunction requires two elements. The first received element is just put into state. Once the second element arrives, both are given to the ReduceFunction and the result is put into state and replaces the first element.
Best, Fabian 2017-06-12 18:25 GMT+02:00 nragon <nuno.goncal...@wedotechnologies.com>: > Hi, > > Regarding ReduceFunction. > Is reduce() called when there is only one record for a given key? > > Thanks > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/ReduceFunction- > mechanism-tp13651.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
