From 985a58a99736d5aa6653883e1766a853c894d77c Mon Sep 17 00:00:00 2001 From: tanjialiang Date: Thu, 2 Jan 2025 13:43:35 +0800 Subject: [PATCH] mvn spotless:apply --- .../paimon/table/PrimaryKeyFileStoreTableTest.java | 9 ++++++--- .../org/apache/parquet/hadoop/ParquetFileReader.java | 3 ++- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyFileStoreTableTest.java b/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyFileStoreTableTest.java index caaf9d8508dc..dc9954367ab1 100644 --- a/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyFileStoreTableTest.java +++ b/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyFileStoreTableTest.java @@ -918,9 +918,12 @@ public void testDeletionVectorsWithParquetFilter() throws Exception { assertThat(result.size()).isEqualTo((200000 - 90000) - (187795 - 93421)); - assertThat(result).doesNotContain("1|93421|9342100|binary|varbinary|mapKey:mapVal|multiset"); - assertThat(result).doesNotContain("1|187794|18779400|binary|varbinary|mapKey:mapVal|multiset"); - assertThat(result).doesNotContain("1|200000|20000000|binary|varbinary|mapKey:mapVal|multiset"); + assertThat(result) + .doesNotContain("1|93421|9342100|binary|varbinary|mapKey:mapVal|multiset"); + assertThat(result) + .doesNotContain("1|187794|18779400|binary|varbinary|mapKey:mapVal|multiset"); + assertThat(result) + .doesNotContain("1|200000|20000000|binary|varbinary|mapKey:mapVal|multiset"); assertThat(result).contains("1|199999|19999900|binary|varbinary|mapKey:mapVal|multiset"); assertThat(result).contains("1|90000|9000000|binary|varbinary|mapKey:mapVal|multiset"); diff --git a/paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java b/paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java index 192e8f064392..3854b3f43989 100644 --- a/paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java +++ b/paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java @@ -394,7 +394,8 @@ private List filterRowGroups(List blocks) throws I RoaringBitmap32.bitmapOfRange( rowIndexOffset, rowIndexOffset + it.getRowCount()); - return !RoaringBitmap32.andNot(range, deletion).isEmpty(); + return !RoaringBitmap32.andNot(range, deletion) + .isEmpty(); }) .collect(Collectors.toList()); }