[apacheGH-3035][ParquetRewriter] extend tests for renaming feature

MaxNevermind · Nov 6, 2024 · a4eccc6 · a4eccc6
1 parent d78132d
commit a4eccc6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/RewriteOptions.java
@@ -21,11 +21,11 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
-import org.apache.curator.shaded.com.google.common.collect.ImmutableSet;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.parquet.Preconditions;
@@ -617,7 +617,7 @@ private void checkPreconditions() {
 
       if (renameColumns != null) {
         Set<String> nullifiedColumns = maskColumns == null
-            ? ImmutableSet.of()
+            ? new HashSet<>()
             : maskColumns.entrySet().stream()
                 .filter(x -> x.getValue() == MaskMode.NULLIFY)
                 .map(Map.Entry::getKey)