Re: mappartition's FlatMapFunction help

2015-09-16 Thread Ankur Srivastava
Good to know it worked for you. CC'ed user group so that the thread reaches a closure. Thanks Ankur On Wed, Sep 16, 2015 at 6:13 AM, Thiago Diniz wrote: > Nailed it. > > Thank you! > > 2015-09-15 14:39 GMT-03:00 Ankur Srivastava : > >> Hi,

Re: mappartition's FlatMapFunction help

2015-09-15 Thread Ankur Srivastava
Hi, The signatures are perfect. I also tried same code on eclipse and for some reason eclipse did not import java.util.Iterator. Once I imported it, it is fine. Might be same issue with NetBeans. Thanks Ankur On Tue, Sep 15, 2015 at 10:11 AM, dinizthiagobr wrote: >

mappartition's FlatMapFunction help

2015-09-15 Thread dinizthiagobr
Can't get this one to work and I have no idea why. JavaPairRDD> lel = gen.groupByKey(); JavaRDD partitions = lel.mapPartitions( new FlatMapFunction>>, String> () { public Iterable call(Iterator>>