跳至主要内容

Iceberg 表引擎

此引擎提供与 Amazon S3、Azure、HDFS 和本地存储的现有 Apache Iceberg 表的只读集成。

创建表

请注意,Iceberg 表必须已存在于存储中,此命令不接受用于创建新表的 DDL 参数。

CREATE TABLE iceberg_table_s3
ENGINE = IcebergS3(url, [, NOSIGN | access_key_id, secret_access_key, [session_token]], format, [,compression])

CREATE TABLE iceberg_table_azure
ENGINE = IcebergAzure(connection_string|storage_account_url, container_name, blobpath, [account_name, account_key, format, compression])

CREATE TABLE iceberg_table_hdfs
ENGINE = IcebergHDFS(path_to_table, [,format] [,compression_method])

CREATE TABLE iceberg_table_local
ENGINE = IcebergLocal(path_to_table, [,format] [,compression_method])

引擎参数

参数的描述与引擎S3AzureBlobStorageHDFSFile中参数的描述一致。format代表 Iceberg 表中数据文件的格式。

可以使用命名集合指定引擎参数

示例

CREATE TABLE iceberg_table ENGINE=IcebergS3('http://test.s3.amazonaws.com/clickhouse-bucket/test_table', 'test', 'test')

使用命名集合

<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>
</iceberg_conf>
</named_collections>
</clickhouse>
CREATE TABLE iceberg_table ENGINE=IcebergS3(iceberg_conf, filename = 'test_table')

别名

表引擎Iceberg现在是IcebergS3的别名。

数据缓存

Iceberg 表引擎和表函数支持与S3AzureBlobStorageHDFS 存储相同的数据缓存。请参阅此处

另请参阅