veryhehe2011
veryhehe2011
采纳率42.9%
2016-04-22 09:03 阅读 1.1k

关于Dstream里reduceByKey()的一个疑问

在Dstream里面有个操作函数是reduceByKey(),大意就是根据该Dstream里面
的每个rdd做一个reduceByKey()的操作, 然后返回一个由新的RDD组成的新的Dstream。
我的疑问是:
1、新的(结果)Dstream里面的不同rdd里,key会重复么?
2、Dstream的内容就是最终的结果呢
还是我应该对这个Dstream里面的Rdd再做一个汇总?

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享