Thanks, Paolo and Mark. :)
On 04 Dec 2014, at 11:58, Paolo Platter paolo.plat...@agilelab.it wrote:
Hi,
rdd.flatMap( e = e._2.map( i = ( i, e._1)))
Should work, but I didn't test it so maybe I'm missing something.
Paolo
Inviata dal mio Windows Phone
Da: Yifan LI
Does this line println(Retuning +string) from the hash function
print what you expect? If you're not seeing that output in the
executor log I'd also put some debug statements in case other, since
your match in the interesting case is conditioned on if(
fieldsList.contains(index)) -- maybe that
