pyspark.streaming.DStream.cache

DStream。 缓存 ( )→pyspark.streaming.dstream.DStream(T]

持续的抽样DStream使用默认存储水平(MEMORY_ONLY)。

以前的

pyspark.streaming.DStream.saveAsTextFiles

下一个

pyspark.streaming.DStream.checkpoint