From d33d19e04875cdad7d88cd73af6e8a8f7d997303 Mon Sep 17 00:00:00 2001 From: herefree <841043203@qq.com> Date: Mon, 16 Dec 2024 20:44:39 +0800 Subject: [PATCH] fix --- .../dynamicbloomfilter/DynamicBloomFilterFileIndex.java | 1 + .../dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java | 1 + .../dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java | 2 +- .../test/java/org/apache/paimon/flink/FlinkFileIndexTest.java | 1 + 4 files changed, 4 insertions(+), 1 deletion(-) diff --git a/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndex.java b/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndex.java index 435da407fa72..db9425330b91 100644 --- a/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndex.java +++ b/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndex.java @@ -40,6 +40,7 @@ import static org.apache.paimon.fileindex.FileIndexResult.REMAIN; import static org.apache.paimon.fileindex.FileIndexResult.SKIP; +/** implementation of dynamic bloom filter file index. */ public class DynamicBloomFilterFileIndex implements FileIndexer { public static final int VERSION_1 = 1; diff --git a/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java b/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java index 69dc7579d6fc..8b569307c161 100644 --- a/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java +++ b/paimon-common/src/main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java @@ -23,6 +23,7 @@ import org.apache.paimon.options.Options; import org.apache.paimon.types.DataType; +/** Factory to create {@link DynamicBloomFilterFileIndexFactory}. */ public class DynamicBloomFilterFileIndexFactory implements FileIndexerFactory { public static final String DYNAMIC_BLOOM_FILTER = "dynamic-bloom-filter"; diff --git a/paimon-common/src/test/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java b/paimon-common/src/test/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java index 4395f99e5200..10c4335fb12d 100644 --- a/paimon-common/src/test/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java +++ b/paimon-common/src/test/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java @@ -132,7 +132,7 @@ public void testAddFindByRandomLong() { @Test public void testCompareFppWithBloomFilter() { - // When the amount of data written to the filter exceeds the number of items, + // When the amount of data written to the filter exceeds the number of item, // the dynamic bloom filter has a smaller error rate than the bloom filter. DynamicBloomFilterFileIndex dynamicFilter = diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkFileIndexTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkFileIndexTest.java index 88a9b267f22e..5737d1c2465d 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkFileIndexTest.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkFileIndexTest.java @@ -37,6 +37,7 @@ import java.util.Set; import java.util.stream.Collectors; +/** ITCase for FileIndex. */ public class FlinkFileIndexTest extends CatalogITCaseBase { @Test