pyspark.streaming.DStream.persist

DStream.persist(storageLevel)

Persist the RDDs of this DStream with the given storage level

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