allow only GZIP as compression algorithm

snowflakedb · Oct 30, 2023 · 8f104b2 · 8f104b2
1 parent 333bc07
commit 8f104b2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 8 deletions.
diff --git a/src/main/java/net/snowflake/ingest/utils/Constants.java b/src/main/java/net/snowflake/ingest/utils/Constants.java
@@ -119,15 +119,10 @@ public static BdecVersion fromInt(int val) {
    * CompressionCodecName, but we want to control and allow only specific values of that.
    */
   public enum BdecParquetCompression {
-    UNCOMPRESSED,
-    GZIP,
-    SNAPPY,
-    ZSTD;
+    GZIP;
 
     public CompressionCodecName getCompressionCodec() {
-      return (this == UNCOMPRESSED
-          ? CompressionCodecName.fromConf(null)
-          : CompressionCodecName.fromConf(this.name()));
+      return CompressionCodecName.fromConf(this.name());
     }
 
     public static BdecParquetCompression fromName(String name) {

diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/ParameterProviderTest.java b/src/test/java/net/snowflake/ingest/streaming/internal/ParameterProviderTest.java
@@ -42,7 +42,7 @@ public void withValuesSet() {
     Assert.assertEquals(1000L, parameterProvider.getMaxMemoryLimitInBytes());
     Assert.assertEquals(1000000L, parameterProvider.getMaxChannelSizeInBytes());
     Assert.assertEquals(
-        Constants.BdecParquetCompression.ZSTD,
+        Constants.BdecParquetCompression.GZIP,
         parameterProvider.getBdecParquetCompressionAlgorithm());
   }