DStream。
mapPartitionsWithIndex
返回一個新的DStream每個抽樣生成通過應用mapPartitionsWithIndex DStream每個抽樣()。
以前的
pyspark.streaming.DStream.mapPartitions
下一個
pyspark.streaming.DStream.mapValues