跳转到主要内容

v0.1 在 Postgres 外部查询列存表

在 pg_mooncake v0.1 中查看 mooncake.columnstore_tables 与 mooncake.data_files,并通过 Python Polars 读取 Delta Lake 表。
pg_mooncake v0.1 历史归档文档(Delta Lake 引擎)

本页归档的是早期 pg_mooncake v0.1 版本文档(采用直接 CREATE TABLE ... USING columnstore DDL 与 Delta Lake 存储)。从 v0.2 及 PGSTY 维护的 v0.3.0 版本起,pg_mooncake 已全面转向基于 moonlink 的实时列存镜像架构(CALL mooncake.create_table + USING mooncake)与 Apache Iceberg v2。最新文档请参阅简介与 v0.1 与 v0.2 / v0.3 架构演进对比。

当前 v0.3.0 元数据查询函数

在 v0.2 与 v0.3.0 中,请使用 SELECT * FROM mooncake.list_tables(); 查看表 LSN 进度与 Apache Iceberg v2 仓库路径。

查找表物理路径(v0.1)

在 v0.1 中,mooncake.columnstore_tables 目录表记录了每张 USING columnstore 表的 Delta Lake 存储路径:

SELECT * FROM mooncake.columnstore_tables;

查看底层 Parquet 数据文件(v0.1)

SELECT * FROM mooncake.data_files;

使用 Python Polars 直接读取 v0.1 Delta Lake 表

import polars as pl

local_path = "/usr/local/pgsql/data/mooncake_local_tables/mooncake_postgres_users_columnstore_16446/"
df = pl.scan_delta(local_path)
print(df.collect())