in paimon-web-api/src/main/java/org/apache/paimon/web/api/table/TableManager.java [426:458]
public static List<FileTableMetadata> listFiles(
Catalog catalog, String dbName, String tableName)
throws Catalog.TableNotExistException, IOException {
checkNotNull(catalog, dbName, tableName);
List<FileTableMetadata> files = new ArrayList<>();
Table table = getTable(catalog, dbName, "`" + tableName + "$" + FILES + "`");
RecordReader<InternalRow> reader = getReader(table);
reader.forEachRemaining(
row -> {
FileTableMetadata fileTableMetadata =
FileTableMetadata.builder()
.partition(row.getString(1).toString())
.bucket(row.getInt(2))
.filePath(row.getString(3).toString())
.fileFormat(row.getString(4).toString())
.schemaId(row.getLong(5))
.level(row.getInt(6))
.fileSizeInBytes(row.getLong(7))
.minKey(row.getString(8).toString())
.maxKey(row.getString(9).toString())
.nullValueCounts(row.getString(10).toString())
.minValueStats(row.getString(11).toString())
.maxValueStats(row.getString(12).toString())
.creationTime(row.getTimestamp(13, 6).toLocalDateTime())
.build();
files.add(fileTableMetadata);
});
return files;
}