从Iceberg文件中读取元数据。
语法
setof record iceberg_metadata (text path, BOOLEAN allow_moved_paths DEFAULT FALSE, TEXT mode DEFAULT '',TEXT metadata_compression_codec DEFAULT 'none', BOOLEAN kip_schema_inference DEFAULT FALSE,TEXT version DEFAULT 'version-hint.text' TEXT version_name_format DEFAULT 'v%s%s.metadata.json,%s%s.metadata.json')参数
参数名称 | 类型 | 默认值 | 描述 |
path | TEXT | N/A | Iceberg文件的路径。路径写法参见URL格式。 |
allow_moved_paths | BOOLEAN | FALSE | 是否允许已移动的Iceberg表。 |
metadata_compression_codec | TEXT | NONE | 读取元数据时使用的压缩编解码器。 |
kip_schema_inference | BOOLEAN | FALSE | 是否跳过模式推断。 |
version | TEXT | version-hint.text | 读取的元数据的版本。 |
version_name_format | TEXT | v%s%s.metadata.json,%s%s.metadata.json | 读取的元数据的版本名称格式。 |
返回值
参数名称 | 描述 |
manifest_path | manifest文件路径。 |
manifest_sequence_number | manifest文件序号。 |
manifest_content | manifest文件内容。 |
status | 文件状态。 |
content | 文件内容。 |
file_path | 文件路径。 |
描述
从Iceberg文件中读取元数据。
示例
示例数据:iceberg_data.zip。
SELECT * FROM iceberg_metadata('oss://<access_key>:<secrect_key>@<endpoint-internal>/<bucket>/path_to/file/lineitem_iceberg', allow_moved_paths => true) ;
manifest_path | manifest_sequence_number | manifest_content | status | content | file_path
---
lineitem_iceberg/metadata/10eaca8a-1e1c-421e-ad6d-b232e5ee23d3-m1.avro | 2 | DATA | ADDED | EXISTING | lineitem_iceberg/data
/00041-414-f3c73457-bbd6-4b92-9c15-17b241171b16-00001.parquet
lineitem_iceberg/metadata/10eaca8a-1e1c-421e-ad6d-b232e5ee23d3-m0.avro | 2 | DATA | DELETED | EXISTING | lineitem_iceberg/data
/00000-411-0792dcfe-4e25-4ca3-8ada-175286069a47-00001.parquet
(2 rows)该文章对您有帮助吗?