2 veryhehe2011 veryhehe2011 于 2016.04.22 17:03 提问

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

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

Csdn user default icon
上传中...
上传图片
插入图片