dgadiraju
5/18/2017 - 11:14 AM

spark-scala-actions-preview-data.scala

val path = "/public/retail_db" or val path = "/Users/itversity/Research/data/retail_db"

val rdd = sc.textFile(path + "/orders")
rdd.first
rdd.take(10)
rdd.collect
rdd.take(10).foreach(println)
rdd.take(10).foreach(k => println(k.split(",")(0) + "\t" + k.split(",")(1)))