Iceberg 表函数
提供对 Amazon S3、Azure、HDFS 或本地存储的 Apache Iceberg 表的只读表式接口。
语法
icebergS3(url [, NOSIGN | access_key_id, secret_access_key, [session_token]] [,format] [,compression_method])
icebergS3(named_collection[, option=value [,..]])
icebergAzure(connection_string|storage_account_url, container_name, blobpath, [,account_name], [,account_key] [,format] [,compression_method])
icebergAzure(named_collection[, option=value [,..]])
icebergHDFS(path_to_table, [,format] [,compression_method])
icebergHDFS(named_collection[, option=value [,..]])
icebergLocal(path_to_table, [,format] [,compression_method])
icebergLocal(named_collection[, option=value [,..]])
参数
参数的描述与表函数 s3
、azureBlobStorage
、HDFS
和 file
的参数描述一致。format
代表 Iceberg 表中数据文件的格式。
返回值一个具有指定结构的表,用于读取指定 Iceberg 表中的数据。
示例
SELECT * FROM icebergS3('http://test.s3.amazonaws.com/clickhouse-bucket/test_table', 'test', 'test')
信息
ClickHouse 目前通过 icebergS3
、icebergAzure
、icebergHDFS
和 icebergLocal
表函数以及 IcebergS3
、icebergAzure
、IcebergHDFS
和 IcebergLocal
表引擎支持读取 Iceberg 格式的 v1 和 v2。
定义命名集合
以下是如何配置用于存储 URL 和凭据的命名集合的示例
<clickhouse>
<named_collections>
<iceberg_conf>
<url>http://test.s3.amazonaws.com/clickhouse-bucket/</url>
<access_key_id>test<access_key_id>
<secret_access_key>test</secret_access_key>
<format>auto</format>
<structure>auto</structure>
</iceberg_conf>
</named_collections>
</clickhouse>
SELECT * FROM icebergS3(iceberg_conf, filename = 'test_table')
DESCRIBE icebergS3(iceberg_conf, filename = 'test_table')
别名
表函数 iceberg
现在是 icebergS3
的别名。
另请参阅