文档首页/ MapReduce服务 MRS/ 组件操作指南(LTS版)/ 使用Paimon/ 基于Paimon系统表查询数据信息
更新时间:2026-06-11 GMT+08:00
分享

基于Paimon系统表查询数据信息

表级系统表

每个表都有对应的系统表,系统表包含每个表相关的元数据及信息。用户可以通过批处理的方式查询对应表的系统表获取快照、Schema、使用选项等详细信息。目前仅Flink、Spark支持查询系统表。在某些情况下,表名需要用反引号包裹,以避免语法解析冲突。例如:
select * from my_catalog.my_db.`my_table$snapshots`
表1 系统表介绍

系统表名称(后缀)

功能说明

示例

$snapshots

查询表的快照历史信息,包括快照ID、提交时间、记录数等。用于了解提交和过期信息,并支持数据时间旅行。

SELECT * FROM my_table$snapshots;

$schemas

查询表的历史模式(Schema)信息,追踪表结构随时间的变化。

SELECT * FROM my_table$schemas;

$options

查询从DDL指定的表选项信息。未显示的选项将使用默认值。

SELECT * FROM my_table$options;

$audit_log

审计表的变更日志。查询结果包含rowkind列(+I、-U、+U、-D),用于过滤和审计操作。

SELECT * FROM my_table$audit_log;

$ro

读优化表。仅扫描无需合并的文件,以牺牲读取数据的新鲜度为代价,提供极致的读取性能。

SELECT * FROM my_table$ro;

$files

查询特定快照下表的文件详情,包括分区、桶、文件路径、记录数、大小、键值范围等。

SELECT * FROM my_table$files;

$tags

查询表的标签历史信息,包括标签基于的快照以及快照的一些历史信息。可用于按标签名称进行时间旅行。

SELECT * FROM my_table$tags;

$consumers

查询所有包含下一个快照的消费者信息。

SELECT * FROM my_table$consumers;

$manifests

查询当前表最新或指定快照中包含的所有清单文件。

SELECT * FROM my_table$manifests;

$aggregation_fields

查询表的历史聚合信息。

SELECT * FROM my_table$aggregation_fields;

$partitions

查询表的分区文件信息。

SELECT * FROM my_table$partitions;

全局系统表

全局系统表提供跨表的统计与配置信息,通过名为sys的系统数据库访问。

表2 全局系统表

系统表名称

功能说明

示例

sys.all_table_options

类似于表级选项表,但显示所有数据库中所有表的选项。

SELECT * FROM sys.all_table_options;

sys.catalog_options

查询目录(Catalog)的选项信息。未显示的选项将使用默认值。

SELECT * FROM sys.catalog_options;

相关文档