How to process list of RDDs, foreach is sequential is there an alternative?
val param = RDD[(id, testNo, catId, value)]
val key = param.map(f => (f.catId, f.testNo)).distinct.collect.toList.par
key.foreach( key => {
// kmeans processing
// get standard deviation
// computation
// etc... etc..
})