Huawei H13-723_V2.0 Exam - Topic 6 Question 69 Discussion

Question

existSpark, assuminglinesIs anDStreamObject, which of the following statements can periodically count the number of words on this stream?

A) lines.flatMap(_.split??)).map(word=>(word,1)).reduce(_+_).print ( )

B) lines.flatMap(_.split??)).map(word=>(word,word.length())).reduceByKey(_+_).print ( )

D) lines.flatMap(_.split??)).flatmap(word=>(word,1)).groupByKey(_+_).print ( )

Accepted Answer

C) lines.flatMap(_.split??)).map(word=>(word,1)).reduceByKey(_+_).print ( )

Contribute your Thoughts: