pyspark.streaming.DStream.cogroup¶
-
DStream。cogroup( 其他:pyspark.streaming.dstream.DStream(元組(K,U]],numPartitions:可選(int]=沒有一個 )→pyspark.streaming.dstream.DStream(元組(K,元組(pyspark.resultiterable.ResultIterable(V] ,pyspark.resultiterable.ResultIterable(U] ] ] ] ¶ -
返回一個新的DStream運用抽樣之間的cogroup DStream和其他DStream。
散列分區用於生成抽樣numPartitions分區。