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