spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Konstantin Kudryavtsev <kudryavtsev.konstan...@gmail.com>
Subject how to convert RDD to PairRDDFunctions ?
Date Tue, 08 Jul 2014 17:25:38 GMT
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

Mime
View raw message