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,
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:
>
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>>