Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val orders = sc.textFile("/public/retail_db/orders")
- // Previewing data
- orders.first
- orders.take(10).foreach(println)
- orders.count
- // Use collect with care.
- // As it creates single threaded list from distributed RDD,
- // using collect on larger datasets can cause out of memory issues.
- orders.collect.foreach(println)
Add Comment
Please, Sign In to add comment