flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: FlatMap on a batch of elements
Date Fri, 21 Nov 2014 09:29:12 GMT
Yes, that's perfectly fine!
Thanks!

On Fri, Nov 21, 2014 at 10:14 AM, Stefan Bunk <stefan.bunk@googlemail.com>
wrote:

> 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