在 Spark 中,假设 lines 是一个 DStream 对象,以下哪个语句可以周期统计这个流上的单词数?
(A)lines.flatMap(_.split”””)).map(word=>(word,1)).reduce(_+_).print()
(B)lines.flatMap(_.split”””)).map(word=>(word,word.length())).reduceByKey(_+_).print()
(C)lines.flatMap(_.split”””)).map(word=>(word,1)).reduceByKey(_+_).print()
(D)lines.flatMap(_.split”””)).flatMap(word=>(word,1)).groupByKey(_+_).print()
参考答案
继续答题:下一题