当先锋百科网

首页 1 2 3 4 5 6 7

要将数据以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压缩数据。如果不设置该属性,则默认是不压缩的。