Re: ReduceFunction mechanism

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

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 <[hidden email]>:

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.