pyspark.streaming.DStream.rightOuterJoin

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

返回一个新的DStream运用抽样之间的右外连接DStream和其他DStream。

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

以前的

pyspark.streaming.DStream.repartition

下一个

pyspark.streaming.DStream.slice