pyspark.streaming.DStream.join

DStream。 加入 ( 其他:pyspark.streaming.dstream.DStream(元组(K,U]],numPartitions:可选(int]=没有一个 )→pyspark.streaming.dstream.DStream(元组(K,元组(V,U] ] ]

返回一个新的DStream通过应用之间的“加入”DStream和抽样其他DStream。

散列分区用于生成抽样numPartitions分区。

以前的

pyspark.streaming.DStream.groupByKeyAndWindow

下一个

pyspark.streaming.DStream.leftOuterJoin