[core][common] Remove useless codes.

hang8929201 · Nov 7, 2024 · 8c68032 · 8c68032
1 parent d3b809f
commit 8c68032
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 22 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java b/paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java
@@ -19,11 +19,8 @@
 package org.apache.paimon.reader;
 
 import org.apache.paimon.annotation.Public;
-import org.apache.paimon.fileindex.FileIndexResult;
-import org.apache.paimon.fileindex.bitmap.BitmapIndexResultLazy;
 import org.apache.paimon.utils.CloseableIterator;
 import org.apache.paimon.utils.Filter;
-import org.apache.paimon.utils.RoaringBitmap32;
 
 import javax.annotation.Nullable;
 
@@ -212,13 +209,4 @@ public void close() throws IOException {
     default CloseableIterator<T> toCloseableIterator() {
         return new RecordReaderIterator<>(this);
     }
-
-    default boolean checkIndexResultExist(
-            FileIndexResult fileIndexResult, long startRowNum, long endRowNum) {
-        if (fileIndexResult instanceof BitmapIndexResultLazy) {
-            RoaringBitmap32 bitmap = ((BitmapIndexResultLazy) fileIndexResult).get();
-            return bitmap.rangeCardinality(startRowNum, endRowNum) > 0;
-        }
-        return true;
-    }
 }
diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/RawFileSplitRead.java b/paimon-core/src/main/java/org/apache/paimon/operation/RawFileSplitRead.java
@@ -194,16 +194,6 @@ private RecordReader<InternalRow> createFileReader(
             throws IOException {
         FileIndexResult fileIndexResult = null;
         if (fileIndexReadEnabled) {
-            //            boolean skip =
-            //                    FileIndexSkipper.skip(
-            //                            fileIO,
-            //                            bulkFormatMapping.getDataSchema(),
-            //                            bulkFormatMapping.getDataFilters(),
-            //                            dataFilePathFactory,
-            //                            file);
-            //            if (skip) {
-            //                return new EmptyRecordReader<>();
-            //            }
             fileIndexResult =
                     FileIndexEvaluator.evaluate(
                             fileIO,