reduceByKey需要输入kv对,然后针对kv对进行操作。


流程示意图如下:

image.png