pyspark.streaming.DStream.fullOuterJoin

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

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

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

以前的

pyspark.streaming.DStream.foreachRDD

下一個

pyspark.streaming.DStream.glom