AI 助理
备案控制台
官方文档
输入文档关键字查找
首页

iceberg_scan

更新时间：
产品详情
我的收藏

从Iceberg文件中读取数据。

语法

setof record iceberg_scan (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

读取的元数据的版本名称格式。

返回值

返回一组数据记录。

描述

从Iceberg文件中读取数据。

示例

示例数据：iceberg_data.zip。

SELECT COUNT(l_orderkey) FROM iceberg_scan('oss://<access_key>:<secrect_key>@<endpoint-internal>/<bucket>/path_to/file/lineitem_iceberg', allow_moved_paths => true) AS (l_orderkey BIGINT);

 count 
-------
 51793