I am planning to use RDD join operation, to test out i was trying to
compile some test code, but am getting following compilation error

*value join is not a member of org.apache.spark.rdd.RDD[(String, Int)]*
*[error]     rddA.join(rddB).map { case (k, (a, b)) => (k, a+b) }*

Code:

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.rdd.RDD

def joinTest(rddA: RDD[(String, Int)], rddB: RDD[(String, Int)]) :
RDD[(String, Int)] = {
    rddA.join(rddB).map { case (k, (a, b)) => (k, a+b) }
}

Any help would be great .

Veera

Reply via email to