要将数据以Parquet格式和Snappy压缩方式写入目录,可以执行以下操作:

  • 注:
    dataframe.write.mode(“xxx”).parquet(“xxx”)默认已经开启snappy压缩

方式1:

INSERT OVERWRITE DIRECTORY '/path/to/output' 
USING PARQUET
OPTIONS ('compression'='snappy')
SELECT * FROM table_name;

方式2:

INSERT OVERWRITE DIRECTORY '/path/to/output' 
STORED AS PARQUET 
TBLPROPERTIES('parquet.compression'='snappy')
SELECT * FROM table_name;

其中,parquet.compression设置为snappy表示使用Snappy压缩数据。如果不设置该属性,则默认是不压缩的。

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐