pyspark.streaming.DStream.groupByKey

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

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

以前的

pyspark.streaming.DStream.glom

下一個

pyspark.streaming.DStream.groupByKeyAndWindow