pyspark.streaming.DStream.persist

DStream。 堅持 ( storageLevel:pyspark.storagelevel.StorageLevel )→pyspark.streaming.dstream.DStream(T]

持續的抽樣DStream與給定的存儲水平

以前的

pyspark.streaming.DStream.partitionBy

下一個

pyspark.streaming.DStream.reduce