WordCount program using scala language (Without using Spark-Core and SQL)
val list = List(“Anish is working on BigData Technologies”,”Hello Anish”,”BigData”)
val words = list.flatMap(line => line.split(” “))
val keyData = words.map(word => (word,1))
val groupedData = keyData.groupBy(_._1)
val result = groupedData.mapValues(list=>{
list.map(_._2).sum
})
result.foreach(println)
Output:
scala> result.foreach(println)
(working,1)
(BigData,2)
(is,1)
(Technologies,1)
(Anish,2)
(on,1)
(Hello,1)