May 2017
Intermediate to advanced
294 pages
7h 33m
English
To persist a DataFrame in a specific compression format, all you have to do is to provide compression as an option like this:
scala> mydf.write.option("compression","snappy").parquet("hdfs://localhost:9000/user/hduser/mydata")
Spark also supports lz4 and lzf, besides Snappy.
Read now
Unlock full access