spark.sql(
"CREATE TABLE local.default.test_per_col ("
+ " int_col int,"
+ " string_col string"
+ ") USING iceberg"
+ " TBLPROPERTIES ("
+ " 'write.parquet.compression-codec' = 'zstd',"
+ " 'write.parquet.compression-codec.column.int_col' = 'snappy'"
+ ")");
Feature Request / Improvement
Enable parquet per column compression based on apache/parquet-java#3526 and apache/parquet-java#3396
Example:
Iceberg table can be created with
Query engine
None
Willingness to contribute