File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
main/java/org/apache/parquet/column/impl
test/java/org/apache/parquet/column/values/bloomfilter Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -58,8 +58,8 @@ abstract class ColumnWriterBase implements ColumnWriter {
5858 private long rowsWrittenSoFar = 0 ;
5959 private int pageRowCount ;
6060
61- private BloomFilterWriter bloomFilterWriter ;
62- private BloomFilter bloomFilter ;
61+ private final BloomFilterWriter bloomFilterWriter ;
62+ private final BloomFilter bloomFilter ;
6363
6464 ColumnWriterBase (
6565 ColumnDescriptor path ,
@@ -72,6 +72,8 @@ abstract class ColumnWriterBase implements ColumnWriter {
7272 this .repetitionLevelColumn = createRLWriter (props , path );
7373 this .definitionLevelColumn = createDLWriter (props , path );
7474 this .dataColumn = props .newValuesWriter (path );
75+ this .bloomFilter = null ;
76+ this .bloomFilterWriter = null ;
7577 }
7678
7779 ColumnWriterBase (
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ public void testBloomFilterForPrimitives() {
7979 private void testBloomFilterForPrimitives (long seed ) {
8080 Random random = new Random (seed );
8181 final int numValues = 1024 * 1024 ;
82- final int numBytes = BlockSplitBloomFilter .optimalNumOfBits (numValues , random .nextDouble ()/ 10 ) / 8 ;
82+ final int numBytes = BlockSplitBloomFilter .optimalNumOfBits (numValues , random .nextDouble () / 10 ) / 8 ;
8383 BloomFilter bloomFilter = new BlockSplitBloomFilter (numBytes );
8484
8585 Set <Object > values = new HashSet <>();
You can’t perform that action at this time.
0 commit comments