答案解析
在Spark中，假设lines是一个Dstream对象，以下哪个语句可以周期统计这个流上的单词数？
- A、Iines.flatMap(_.split"")).map(word=>(word,1)).reduce(_+_).print()
- B、Iines.flatMap(_.split"")).map(word=>(word,word.length()))).reduceukey(_+_).print()
- C、Iines.flatMap(_.split"")).flatap(word=>(word,1)).reduceBykey(_+_).print()
- D、Iines.flatMap(_.split"")).flatap(word=>(word,1)).groupByKey(_+_).print()
挑战成功
2年前
挑战失败
2年前
挑战失败
2年前
挑战成功
3年前
挑战成功
3年前
挑战失败
3年前
挑战成功
3年前
挑战成功
3年前
挑战成功
3年前
挑战成功
3年前
