SPARK 持久化示例

【问题标题】：SPARK persist exampleSPARK 持久化示例
【发布时间】：2020-03-12 06:26:36
【问题描述】：

任何人都可以帮助如何将持久存储级别设置/重置为与默认不同的级别。我尝试了以下，我可能不正确。请帮我改正。

代码如下：

scala> val lines = sc.textFile("/data/retail_db/products/part-00000").persist(StorageLevel.MEMORY_AND_DISK)
<console>:27: error: not found: value StorageLevel

【问题讨论】：

标签： apache-spark apache-spark-sql bigdata

【解决方案1】：

你只需要在使用之前导入StorageLevel，就像那样

import org.apache.spark.storage.StorageLevel

【讨论】：

是的，它有效。我忘了导入库。谢谢
如果答案对您有帮助，请考虑accept它。