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