fix

herefree · Dec 16, 2024 · d33d19e · d33d19e
1 parent 8e83455
commit d33d19e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 1 deletion.
diff --git a/...main/java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndex.java b/...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/...va/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexFactory.java b/...va/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/.../java/org/apache/paimon/fileindex/dynamicbloomfilter/DynamicBloomFilterFileIndexTest.java b/.../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/...n-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkFileIndexTest.java b/...n-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