This is about lecture 68:
What I want is to inspect the value of the l_map below:
val l = List(“Hello”, “How are you doing”, “Let us perform word count”, “As part of the word count program”, “we will see how many times each word repeat”)
//create RDD by parallelize the list
val l_rdd = sc.parallelize(l)
How are you doing
Let us perform word count
As part of the word count program
we will see how many times each word repeat
//create a new RDD using map on the RDD
val l_map = l_rdd.map(ele => ele.split(" "))
Can anyone help?
Thank you very much.