Thanks for the help everyone. I got the mapValues approach working. I will experiment with the reduceByKey approach later.
<3 -Kris -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Computing-mean-and-standard-deviation-by-key-tp11192p11214.html Sent from the Apache Spark User List mailing list archive at Nabble.com.