icebergCluster 表函数

这是对 iceberg 表函数的扩展。

允许在指定集群中的多个节点上并行处理来自 Apache Iceberg 的文件。在发起节点上，它会创建到集群中所有节点的连接，并为每个文件进行动态分发。在工作节点上，它会向发起节点请求下一个要处理的任务并对其进行处理。这个过程会反复进行，直到所有任务都完成为止。

语法

icebergS3Cluster(cluster_name, url [, NOSIGN | access_key_id, secret_access_key, [session_token]] [,format] [,compression_method])
icebergS3Cluster(cluster_name, named_collection[, option=value [,..]])

icebergAzureCluster(cluster_name, connection_string|storage_account_url, container_name, blobpath, [,account_name], [,account_key] [,format] [,compression_method])
icebergAzureCluster(cluster_name, named_collection[, option=value [,..]])

icebergHDFSCluster(cluster_name, path_to_table, [,format] [,compression_method])
icebergHDFSCluster(cluster_name, named_collection[, option=value [,..]])

参数

• cluster_name — 用于构建访问远程和本地服务器所需的一组地址和连接参数的集群名称。
• 其他所有参数的说明与等价的 iceberg 表函数中的参数说明一致。

返回值

一个具有指定结构的表，用于从集群中读取指定 Iceberg 表的数据。

示例

SELECT * FROM icebergS3Cluster('cluster_simple', 'http://test.s3.amazonaws.com/clickhouse-bucket/test_table', 'test', 'test')

虚拟列

• _path — 文件路径。类型：LowCardinality(String)。
• _file — 文件名。类型：LowCardinality(String)。
• _size — 文件大小（字节）。类型：Nullable(UInt64)。如果文件大小未知，则该值为 NULL。
• _time — 文件的最后修改时间。类型：Nullable(DateTime)。如果时间未知，则该值为 NULL。
• _etag — 文件的 etag。类型：LowCardinality(String)。如果 etag 未知，则该值为 NULL。

另请参阅

• Iceberg 引擎
• Iceberg 表函数