Ejemplo WordCount en Spark:

val file = spark.textFile("hdfs://...")
val counts = file.flatMap(line => line.split(" "))
                 .map(word => (word, 1))
                 .reduceByKey(_ + _)

Como se puede observar, mucho más "sencillo" que el WordCount en MapReduce