pyspark.streaming.DStream.persist

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

持续的抽样DStream与给定的存储水平

以前的

pyspark.streaming.DStream.partitionBy

下一个

pyspark.streaming.DStream.reduce