[flink] Add fileIndex method in anonymous implementation class of For…

…matReaderFactory.Context.
apache · Nov 7, 2024 · d3b809f · d3b809f
1 parent 7278b6c
commit d3b809f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...g/apache/paimon/flink/compact/changelog/format/CompactedChangelogFormatReaderFactory.java b/...g/apache/paimon/flink/compact/changelog/format/CompactedChangelogFormatReaderFactory.java
@@ -20,6 +20,7 @@
 
 import org.apache.paimon.catalog.CatalogContext;
 import org.apache.paimon.data.InternalRow;
+import org.apache.paimon.fileindex.FileIndexResult;
 import org.apache.paimon.format.FormatReaderFactory;
 import org.apache.paimon.fs.FileIO;
 import org.apache.paimon.fs.FileStatus;
@@ -80,6 +81,11 @@ public Path filePath() {
                     public long fileSize() {
                         return length;
                     }
+
+                    @Override
+                    public FileIndexResult fileIndex() {
+                        return context.fileIndex();
+                    }
                 });
     }