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 <[email protected]>
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?
>
>
