CREATE CATALOG <catalog_name>
TYPE = ICEBERG
CONNECTION = (
    TYPE = '<catalog_type>'
    [ ADDRESS = '<catalog_address>' ]
    [ WAREHOUSE = '<warehouse_location>' ]
    [ "<connection_parameter>" = '<connection_parameter_value>' ]
    ...
);

パラメータ

パラメータ	必須	説明
`<catalog_name>`	はい	TiDB Cloud Lake 内のカタログ名。
`TYPE`	はい	カタログエンジン。この値を `ICEBERG` に設定します。
`CONNECTION`	はい	Iceberg カタログおよびそのストレージの接続プロパティ。
`CONNECTION` 内の `TYPE`	はい	Iceberg カタログタイプ: `rest`、`glue`、`storage`、または `hive`。
`ADDRESS`	カタログタイプによる	カタログサービスのエンドポイント、または Hive Metastore のアドレス。
`WAREHOUSE`	カタログタイプによる	カタログで使用される warehouse の場所。
`<connection_parameter>`	カタログタイプによる	カタログ、認証、およびオブジェクトストレージのプロパティ。

以下の接続パラメータは、S3 互換ストレージで使用できます。

接続パラメータ	説明
`s3.endpoint`	S3 互換サービスのエンドポイント。
`s3.access-key-id`	S3 access key ID。
`s3.secret-access-key`	S3 secret access key。
`s3.session-token`	一時クレデンシャルとともに使用するセッショントークン。
`s3.region`	S3 リージョン。
`client.region`	クライアントで使用されるリージョン。この値は `s3.region` より優先されます。
`s3.path-style-access`	path-style の S3 アクセスを使用するかどうか。
`s3.sse.type`	サーバー側暗号化のタイプ。
`s3.sse.key`	KMS key ID、または顧客提供の暗号化キー。
`s3.sse.md5`	顧客提供の暗号化キーに対する MD5 チェックサム。
`client.assume-role.arn`	引き受ける IAM ロールの ARN。
`client.assume-role.external-id`	IAM ロールを引き受ける際に使用する外部 ID。
`client.assume-role.session-name`	IAM ロールを引き受ける際に使用するセッション名。
`s3.allow-anonymous`	パブリックストレージへの匿名アクセスを許可するかどうか。
`s3.disable-ec2-metadata`	EC2 インスタンスメタデータからのクレデンシャルを無効にするかどうか。
`s3.disable-config-load`	ローカル設定ソースからのクレデンシャルおよび設定の読み込みを無効にするかどうか。

サポートされるカタログタイプ

TiDB Cloud Lake は、以下の Iceberg カタログタイプをサポートしています。

カタログタイプ	`TYPE` 値	接続要件
REST	`rest`	REST カタログアドレス、warehouse の場所、およびストレージプロパティ。
AWS Glue	`glue`	Glue リージョンと認証プロパティに加え、S3 ストレージプロパティ。
Storage (Amazon S3 Tables)	`storage`	テーブルバケット ARN と AWS クライアント認証プロパティ。
Hive Metastore	`hive`	Hive Metastore アドレス、warehouse の場所、およびストレージプロパティ。

Storage カタログは、以下の AWS クライアントプロパティをサポートします。

接続パラメータ	説明
`table_bucket_arn`	Amazon S3 Tables のテーブルバケットの ARN。
`profile_name`	AWS プロファイル名。
`region_name`	AWS リージョン。
`aws_access_key_id`	AWS access key ID。
`aws_secret_access_key`	AWS secret access key。
`aws_session_token`	一時クレデンシャルとともに使用する AWS セッショントークン。

Iceberg カタログを管理およびクエリする

カタログを確認および選択するには、以下のステートメントを使用します。

SHOW CREATE CATALOG <catalog_name>;

SHOW CATALOGS [ LIKE '<pattern>' | WHERE <expression> ];

USE CATALOG <catalog_name>;

詳細は、SHOW CREATE CATALOG および SHOW CATALOGS を参照してください。

カタログを選択した後は、標準 SQL を使用してそのテーブルをクエリします。

SELECT <select_list>
FROM [ <catalog_name>. ]<database_name>.<table_name>
[ WHERE <condition> ];

データ型マッピング

以下の表は、Iceberg 型から TiDB Cloud Lake 型へのサポートされるマッピングを示しています。ここに記載されていない Iceberg 型はサポートされません。

Apache Iceberg™	TiDB Cloud Lake
BOOLEAN	BOOLEAN
INT	INT32
LONG	INT64
DATE	DATE
TIMESTAMP / TIMESTAMPZ	TIMESTAMP
FLOAT	FLOAT
DOUBLE	DOUBLE
STRING / BINARY	STRING
DECIMAL	DECIMAL
LIST	ARRAY
MAP	MAP
STRUCT	TUPLE

キャッシュされたメタデータを更新する

TiDB Cloud Lake は、最初のクエリ後に Iceberg カタログのメタデータをキャッシュします。メタデータキャッシュの有効期間はデフォルトで 10 分で、非同期に更新されます。

キャッシュされたメタデータをすぐに更新する必要がある場合は、以下のステートメントを使用します。

USE CATALOG <catalog_name>;
ALTER DATABASE <database_name> REFRESH CACHE;
ALTER TABLE <database_name>.<table_name> REFRESH CACHE;

TiDB Cloud Lake は、Iceberg カタログから読み取ったテーブルデータのキャッシュもサポートしています。

Iceberg テーブルに書き込む

書き込み操作をサポートするカタログでは、Iceberg テーブルを作成して書き込むことができます。

テーブルを作成する

CREATE TABLE [ <database_name>. ]<table_name> (
    <column_name> <data_type> [ , ... ]
)
ENGINE = ICEBERG
[ PARTITION BY ( <column_name> [ , ... ] ) ];

パラメータ	説明
`ENGINE = ICEBERG`	テーブルを Iceberg 形式で保存します。
`PARTITION BY`	1 つ以上のパーティションカラムを定義します。

Iceberg テーブルへの書き込み時には、以下の TiDB Cloud Lake データ型がサポートされます。

TiDB Cloud Lake 型	Apache Iceberg™ 型
BOOLEAN	Boolean
INT	Int
BIGINT	Long
FLOAT	Float
DOUBLE	Double
STRING	String
DATE	Date
TIMESTAMP	Timestamp

データを挿入する

INSERT INTO を使用して Iceberg テーブルに行を書き込みます。

INSERT INTO [ <database_name>. ]<table_name>
[ ( <column_name> [ , ... ] ) ]
VALUES ( <value> [ , ... ] ) [ , ... ];

パーティションテーブルと非パーティションテーブルの両方で、単一行および複数行の挿入をサポートしています。パーティションテーブルの場合、TiDB Cloud Lake は行を対応するパーティションにルーティングします。

Iceberg テーブル関数

Iceberg メタデータを調査するには、次のテーブル関数を使用します。

Apache Iceberg™ Tables

Iceberg を使用する場合

Iceberg カタログを作成する

構文