pyspark.streaming.DStream.persist

DStream.persist(storageLevel: pyspark.storagelevel.StorageLevel) → pyspark.streaming.dstream.DStream[T]

Persist the RDDs of this DStream with the given storage level

pyspark.streaming.DStream.partitionBy pyspark.streaming.DStream.reduce