From a4eccc640cf92b59c81091fe73b1b1de49fad163 Mon Sep 17 00:00:00 2001 From: maxim_konstantinov Date: Tue, 5 Nov 2024 23:48:06 -0800 Subject: [PATCH] [GH-3035][ParquetRewriter] extend tests for renaming feature --- .../org/apache/parquet/hadoop/rewrite/RewriteOptions.java | 4 ++-- 1 file changed, 2 insertions(+), 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 index 0dc76b8a2a..a2a1c18e32 100644 --- 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 nullifiedColumns = maskColumns == null - ? ImmutableSet.of() + ? new HashSet<>() : maskColumns.entrySet().stream() .filter(x -> x.getValue() == MaskMode.NULLIFY) .map(Map.Entry::getKey)