flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefan Bunk <stefan.b...@googlemail.com>
Subject Re: FlatMap on a batch of elements
Date Fri, 21 Nov 2014 09:14:53 GMT
Hi,

maybe mapPartition ("Transforms a parallel partition in a single function
call. The function get the partition as an `Iterator` and can produce an
arbitrary number of result values.") is the right thing for you?

Cheers
Stefan

On Fri, Nov 21, 2014 at 10:08 AM, Flavio Pompermaier <pompermaier@okkam.it>
wrote:

> Hy all,
> in my FlatMap function I'd like to call a service every 100 elements.
> That would be possible if Collector was passed to the close function but
> it is not.
> How can I simulate that?
>
>

Mime
View raw message