Hi,
Can someone help me with the following error:

scala> val rdd = sc.parallelize(Array(1,2,3,4))
rdd: org.apache.spark.rdd.RDD[Int] = ParallelCollectionRDD[0] at
parallelize at <console>:12

scala> rdd.persist(StorageLevel.MEMORY_ONLY)
<console>:15: error: not found: value StorageLevel
              rdd.persist(StorageLevel.MEMORY_ONLY)
                          ^


Thank you!!!

Reply via email to