Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val sqlContext = new org.apache.spark.sql.SQLContext(sc)
- val df = sqlContext.read.parquet("/path/to/file/without/hdfs://")
- df.printSchema
- df.count
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement