Spark RDD-2-持久化&容錯機制

rdd.cache 默認調用persisi，之緩存內存 def cache(): this.type = persist() rdd.persist() def persist(): this.type = persist(StorageLevel.MEMORY_ONLY) rdd.unpersist(true) 手動釋放緩存RDD佔用的內存、磁盤存儲資源 rdd.checkpoint：容錯 ch

>>阅读原文<<