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