pyspark.streaming.DStream.leftOuterJoin

DStream。 leftOuterJoin ( 其他:pyspark.streaming.dstream.DStream(元組(K,U]],numPartitions:可選(int]=沒有一個 )→pyspark.streaming.dstream.DStream(元組(K,元組(V,可選(U] ] ] ]

返回一個新的DStream運用抽樣之間的左外連接DStream和其他DStream。

散列分區用於生成抽樣numPartitions分區。

以前的

pyspark.streaming.DStream.join

下一個

pyspark.streaming.DStream.map