pyspark.streaming.DStream.combineByKey

DStream。 combineByKey ( createCombiner:可調用的((V],U],mergeValue:可調用的((U,V],U],mergeCombiners:可調用的((U,U],U],numPartitions:可選(int]=沒有一個 )→pyspark.streaming.dstream.DStream(元組(K,U] ]

返回一個新的DStream運用combineByKey抽樣。

以前的

pyspark.streaming.DStream.cogroup

下一個

pyspark.streaming.DStream.context