If your RDD contains pairs, like an RDD[(String,Integer)] or something, then you get to use the functions in PairRDDFunctions as if they were declared on RDD.
On Tue, Jul 8, 2014 at 6:25 PM, Konstantin Kudryavtsev < kudryavtsev.konstan...@gmail.com> wrote: > Hi all, > > sorry for fooly question, but how can I get PairRDDFunctions RDD? I'm > doing it to perform leftOuterJoin aftewards > > currently I do in this was (it seems incorrect): > val parRDD = new PairRDDFunctions( oldRdd.map(i => (i.key, i)) ) > > I guess this constructor is definitely wrong... > > > Thank you, > Konstantin Kudryavtsev >
