distinct算子

下面是distinct算子源码

关键看这一句

对分区内数据先进行map操作，接着调用reduceByKey对同组内数据进行（x,_）=>x 函数操作。

标签：map,distinct,对分,reduceByKey,源码,算子
来源： https://www.cnblogs.com/xstCoding/p/15682886.html