diff --git a/presto-docs/src/main/sphinx/connector/iceberg.rst b/presto-docs/src/main/sphinx/connector/iceberg.rst index dcfef634da5eb..a487508fa5c12 100644 --- a/presto-docs/src/main/sphinx/connector/iceberg.rst +++ b/presto-docs/src/main/sphinx/connector/iceberg.rst @@ -345,7 +345,7 @@ Property Name Description ``iceberg.file-format`` The storage file format for Iceberg tables. The available ``PARQUET`` Yes No, write is not supported yet values are ``PARQUET`` and ``ORC``. -``iceberg.compression-codec`` The compression codec to use when writing files. The ``GZIP`` Yes No, write is not supported yet +``iceberg.compression-codec`` The compression codec to use when writing files. The ``ZSTD`` Yes No, write is not supported yet available values are ``NONE``, ``SNAPPY``, ``GZIP``, ``LZ4``, and ``ZSTD``. diff --git a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/IcebergConfig.java b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/IcebergConfig.java index 86d4f0118113c..720bdd1e02151 100644 --- a/presto-iceberg/src/main/java/com/facebook/presto/iceberg/IcebergConfig.java +++ b/presto-iceberg/src/main/java/com/facebook/presto/iceberg/IcebergConfig.java @@ -33,7 +33,7 @@ import static com.facebook.airlift.units.DataSize.Unit.MEGABYTE; import static com.facebook.airlift.units.DataSize.succinctDataSize; -import static com.facebook.presto.hive.HiveCompressionCodec.GZIP; +import static com.facebook.presto.hive.HiveCompressionCodec.ZSTD; import static com.facebook.presto.iceberg.CatalogType.HIVE; import static com.facebook.presto.iceberg.IcebergFileFormat.PARQUET; import static com.facebook.presto.iceberg.util.StatisticsUtil.decodeMergeFlags; @@ -47,7 +47,7 @@ public class IcebergConfig { private IcebergFileFormat fileFormat = PARQUET; - private HiveCompressionCodec compressionCodec = GZIP; + private HiveCompressionCodec compressionCodec = ZSTD; private CatalogType catalogType = HIVE; private String catalogWarehouse; private String catalogWarehouseDataDir; diff --git a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergConfig.java b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergConfig.java index 59b07b26db5a1..4a8650175e553 100644 --- a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergConfig.java +++ b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergConfig.java @@ -24,8 +24,8 @@ import static com.facebook.airlift.configuration.testing.ConfigAssertions.recordDefaults; import static com.facebook.airlift.units.DataSize.Unit.MEGABYTE; import static com.facebook.airlift.units.DataSize.succinctDataSize; -import static com.facebook.presto.hive.HiveCompressionCodec.GZIP; import static com.facebook.presto.hive.HiveCompressionCodec.NONE; +import static com.facebook.presto.hive.HiveCompressionCodec.ZSTD; import static com.facebook.presto.iceberg.CatalogType.HADOOP; import static com.facebook.presto.iceberg.CatalogType.HIVE; import static com.facebook.presto.iceberg.IcebergFileFormat.ORC; @@ -46,7 +46,7 @@ public void testDefaults() { assertRecordedDefaults(recordDefaults(IcebergConfig.class) .setFileFormat(PARQUET) - .setCompressionCodec(GZIP) + .setCompressionCodec(ZSTD) .setCatalogType(HIVE) .setCatalogWarehouse(null) .setCatalogWarehouseDataDir(null) diff --git a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergSystemTables.java b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergSystemTables.java index 9aea675def5c0..88f2545499ba5 100644 --- a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergSystemTables.java +++ b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/TestIcebergSystemTables.java @@ -286,7 +286,7 @@ protected void checkTableProperties(String schemaName, String tableName, String .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.format.default", "PARQUET"))) .anySatisfy(row -> assertThat(row) - .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.parquet.compression-codec", "GZIP"))) + .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.parquet.compression-codec", "ZSTD"))) .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "commit.retry.num-retries", "4"))) .anySatisfy(row -> assertThat(row) @@ -321,7 +321,7 @@ protected void checkORCFormatTableProperties(String tableName, String deleteMode .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.format.default", "ORC"))) .anySatisfy(row -> assertThat(row) - .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.orc.compression-codec", "ZLIB"))) + .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.orc.compression-codec", "ZSTD"))) .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.parquet.compression-codec", "zstd"))) .anySatisfy(row -> assertThat(row) diff --git a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/nessie/TestIcebergSystemTablesNessie.java b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/nessie/TestIcebergSystemTablesNessie.java index 5f2916e04c1c8..e334d08ca0be6 100644 --- a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/nessie/TestIcebergSystemTablesNessie.java +++ b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/nessie/TestIcebergSystemTablesNessie.java @@ -109,7 +109,7 @@ protected void checkTableProperties(String tableName, String deleteMode) .anySatisfy(row -> assertThat(row.getField(0)).isEqualTo("nessie.commit.id")) .anySatisfy(row -> assertThat(row).isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "gc.enabled", "false"))) .anySatisfy(row -> assertThat(row) - .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.parquet.compression-codec", "GZIP"))) + .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.parquet.compression-codec", "ZSTD"))) .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.metadata.delete-after-commit.enabled", "false"))) .anySatisfy(row -> assertThat(row) @@ -141,7 +141,7 @@ protected void checkORCFormatTableProperties(String tableName, String deleteMode .anySatisfy(row -> assertThat(row) .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.format.default", "ORC"))) .anySatisfy(row -> assertThat(row) - .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.orc.compression-codec", "ZLIB"))) + .isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "write.orc.compression-codec", "ZSTD"))) .anySatisfy(row -> assertThat(row.getField(0)).isEqualTo("nessie.commit.id")) .anySatisfy(row -> assertThat(row).isEqualTo(new MaterializedRow(MaterializedResult.DEFAULT_PRECISION, "gc.enabled", "false"))) .anySatisfy(row -> assertThat(row)