In Spark, assuming that lines is a DStream object, which of the following statements can periodically count the number of words on this stream?

Question

Options

• AIines.flatMap(.split" "")).map(word => (word, 1)).reduce( +_).print()
• BIines.flatMap(.split" "")).map(word => (word,word.Iength())).reduceByKey ( +_).print()
• CIines.fIatMap(.spIit" "")).map(word => (word, 1)).reduceByKey( +_).print()
• DIines.flatMap(.split" "")).flatMap(word => (word, 1)).groupByKey( +_).print()

• A
  12% (6)
• B
  6% (3)
• C
  78% (39)
• D
  4% (2)

No community discussion yet for this question.