That's the approach I finally used.
Thanks for your help :-)
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Joining-not-pair-RDDs-in-Spark-tp5034p5099.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
In the context of telecom industry, let's supose we have several existing
RDDs populated from some tables in Cassandra:
val callPrices: RDD[PriceRow]
val calls: RDD[CallRow]
val offersInCourse: RDD[OfferRow]
where types are defined as follows,
/** Represents the p
