Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // RDD from files in HDFS
- val orders = sc.textFile("/public/retail_db/orders")
- // RDD from files in local file system
- val productsRaw = scala.io.Source.fromFile("/data/retail_db/products/part-00000").getLines.toList
- val products = sc.parallelize(productsRaw)
Add Comment
Please, Sign In to add comment
