I took that RDD run through it and printed 4 elements from it, they all
printed correctly.
val x = viEvents.map {
case (itemId, event) =>
println(event.get("guid"), itemId, event.get("itemId"),
event.get("siteId"))
(itemId, event)
}
The above code prints
(27c9fbc014b4f
I have two RDD
leftRDD = RDD[(Long, (DetailInputRecord, VISummary, Long))]
and
rightRDD =
RDD[(Long, com.ebay.ep.poc.spark.reporting.process.model.dw.SpsLevelMetricSum)
DetailInputRecord is a object that contains (guid, sessionKey,
sessionStartDAte, siteID)
There are 10 records in leftRDD (confi
