pyspark.streaming.DStream.cache

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

持續的抽樣DStream使用默認存儲水平(MEMORY_ONLY)。

以前的

pyspark.streaming.DStream.saveAsTextFiles

下一個

pyspark.streaming.DStream.checkpoint