快速压缩

Question

我正在尝试将 avro 文件存储为具有快速压缩的 parquet 文件。尽管数据被写入为带有 filename.snappy.parquet 的镶木地板，但文件大小保持不变。粘贴代码。

代码：

sqlContext.setConf("spark.sql.parquet.compression.codec","snappy") 

orders_avro.write.parquet("/user/cloudera/problem5/parquet-snappy-compress")

Answer 1

Snappy 压缩是 parquet-mr（Spark 用来编写 Parquet 文件的库）中的默认值。所以这里唯一改变的是文件名。