flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: ReduceFunction mechanism
Date Mon, 12 Jun 2017 19:38:12 GMT
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.goncalves@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.
>

Mime
View raw message