you need import StorageLevel by:
import org.apache.spark.storage.StorageLevel
taoist...@gmail.com
From: rapelly kartheek
Date: 2014-08-25 18:22
To: user
Subject: StorageLevel error.
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!!!