diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetOutputFormat.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetOutputFormat.java index 7a0b277ef9..4a72134d37 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetOutputFormat.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetOutputFormat.java @@ -224,12 +224,12 @@ public static int getBloomFilterMaxBytes(Configuration conf) { ParquetProperties.DEFAULT_MAX_BLOOM_FILTER_BYTES); } - public static Set getBloomFilterColumns(Configuration conf) { + public static Set getBloomFilterColumns(Configuration conf) { String columnNames = conf.get(BLOOM_FILTER_COLUMN_NAMES); if (columnNames != null) { return new HashSet<>(Arrays.asList(columnNames.split(","))); } else { - return new HashSet(); + return new HashSet<>(); } } diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java index f098484973..638d4e7748 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java @@ -1,4 +1,4 @@ -/* +/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information @@ -6,9 +6,9 @@ * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY @@ -544,10 +544,10 @@ public SELF withPageWriteChecksumEnabled(boolean enablePageWriteChecksum) { * * @return this builder for method chaining. */ - public SELF withBloomFilterColumnNames(String columnNames) { + public SELF withBloomFilterColumnNames(String... columnNames) { if (columnNames != null) { encodingPropsBuilder.withBloomFilterColumnNames( - new HashSet<>(Arrays.asList(columnNames.split(","))) + new HashSet<>(Arrays.asList(columnNames)) ); }