(paimon) branch master updated: [core] add data-evolution info to Files System Table. (#6986)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 07e3e9af28 [core] add data-evolution info to Files System Table. 
(#6986)
07e3e9af28 is described below

commit 07e3e9af284cb75af91c9e2d6d4fd0617a7ddfaf
Author: Faiz <wxy407...@antgroup.com>
AuthorDate: Fri Jan 9 11:33:46 2026 +0800

    [core] add data-evolution info to Files System Table. (#6986)
---
 .../java/org/apache/paimon/table/system/FilesTable.java  | 16 ++++++++++++++--
 .../org/apache/paimon/table/system/FilesTableTest.java   |  4 +++-
 2 files changed, 17 insertions(+), 3 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java 
b/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java
index caa8315eb9..b6cae80180 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java
@@ -22,6 +22,7 @@ import org.apache.paimon.casting.CastExecutor;
 import org.apache.paimon.casting.CastExecutors;
 import org.apache.paimon.data.BinaryRow;
 import org.apache.paimon.data.BinaryString;
+import org.apache.paimon.data.GenericArray;
 import org.apache.paimon.data.GenericRow;
 import org.apache.paimon.data.InternalArray;
 import org.apache.paimon.data.InternalRow;
@@ -117,7 +118,9 @@ public class FilesTable implements ReadonlyTable {
                             new DataField(14, "max_sequence_number", new 
BigIntType(true)),
                             new DataField(15, "creation_time", 
DataTypes.TIMESTAMP_MILLIS()),
                             new DataField(16, "deleteRowCount", 
DataTypes.BIGINT()),
-                            new DataField(17, "file_source", 
DataTypes.STRING())));
+                            new DataField(17, "file_source", 
DataTypes.STRING()),
+                            new DataField(18, "first_row_id", 
DataTypes.BIGINT()),
+                            new DataField(19, "write_cols", 
DataTypes.ARRAY(DataTypes.STRING()))));
 
     private final FileStoreTable storeTable;
 
@@ -435,7 +438,16 @@ public class FilesTable implements ReadonlyTable {
                         () -> file.deleteRowCount().orElse(null),
                         () ->
                                 BinaryString.fromString(
-                                        
file.fileSource().map(FileSource::toString).orElse(null))
+                                        
file.fileSource().map(FileSource::toString).orElse(null)),
+                        file::firstRowId,
+                        () -> {
+                            List<String> writeCols = file.writeCols();
+                            if (writeCols == null) {
+                                return null;
+                            }
+                            return new GenericArray(
+                                    
writeCols.stream().map(BinaryString::fromString).toArray());
+                        },
                     };
 
             return new LazyGenericRow(fields);
diff --git 
a/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java 
b/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java
index 343cf236e3..b876480064 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/table/system/FilesTableTest.java
@@ -222,7 +222,9 @@ public class FilesTableTest extends TableTestBase {
                             file.creationTime(),
                             file.deleteRowCount().orElse(null),
                             BinaryString.fromString(
-                                    
file.fileSource().map(Object::toString).orElse(null))));
+                                    
file.fileSource().map(Object::toString).orElse(null)),
+                            file.firstRowId(),
+                            null));
         }
         return expectedRow;
     }