pyspark.RDD.groupWith

抽样。 groupWith ( 其他:pyspark.rdd.RDD(元组(任何,任何]],*其他人:pyspark.rdd.RDD(元组(任何,任何]] )→pyspark.rdd。抽样(元组(Tuple (pyspark.resultiterable。ResultIterable(任何)…]]]

别名cogroup但支持多种抽样。

例子

> > >w=sc并行化(((“一个”,5),(“b”,6)))> > >x=sc并行化(((“一个”,1),(“b”,4)))> > >y=sc并行化(((“一个”,2)))> > >z=sc并行化(((“b”,42)))> > >((x,元组(地图(列表,y)))x,y排序(列表(wgroupWith(x,y,z)收集())))[(a, ([5], [1], [2], [])), (“b”, ([6]、[4]、[], [42])))