ReduceByKey Avereage

Question

How can we find average on a key-value pair using reduceByKey transformation?

Answer 1

You can try the code mentioned below to do this:

val f = List(("panda",1),("pink",2),("panda",2),("pink",3))
rdd.mapValues(value=>(value,1))
rdd.collect