Apache Iceberg™ テーブル:Apache Iceberg™ v3のサポート（プレビュー）¶

データ型¶

次のv3データ型が、パブリックプレビューでサポートされています。

• geography

• geometry

• nanosecond

• variant

詳細については、 Iceberg v3データ型 をご参照ください。

デフォルト値¶

:ref:`デフォルト値<label-tables_iceberg_default_values>`を参照してください。

削除ベクター¶

:ref:`削除ベクター<tables-iceberg-deletion-vectors>`を参照してください。

行系統¶

:ref:`行系統<label-tables_iceberg_row_lineage>`を参照してください。

使用上の注意¶

• アカウントレベルでICEBERG_VERSION_DEFAULTパラメーターを変更するには、アカウント管理者である必要があります。つまり、ACCOUNTADMINロールを持つユーザーである必要があります。

• データベースまたはスキーマレベルでICEBERG_VERSION_DEFAULTパラメーターを変更するには、操作の実行に使用されるロールに、それぞれのデータベースまたはスキーマに対するOWNERSHIP権限が必要です。

例¶

``my_db``データベース内の新しいIcebergテーブルがv3を使用して作成されるように指定します。

ALTER DATABASE my_db SET ICEBERG_VERSION_DEFAULT=3;

v3で新しい外部管理Icebergテーブルを作成します。コマンドに含まれる列定義は、リモートカタログで新しいテーブルが作成されるか、既存のテーブルが置換されることを示します。これは既存のバージョンを持たない新しいテーブルであるため、テーブルは正常に作成されます。

CREATE OR REPLACE ICEBERG TABLE my_iceberg_v3_table (
    boolean_col boolean,
    int_col int,
    long_col long,
  )
  CATALOG='my_catalog_integration'
  ICEBERG_VERSION=3;

Icebergメタデータを持つ既存のテーブルからv3で外部管理Icebergテーブルを作成します。この例で列定義または形式バージョンがないことは、このテーブルが既に存在し、列仕様と形式バージョンがリモートカタログのIcebergメタデータから推測されることを示しています。この例では:doc:`カタログ提供の認証情報</user-guide/tables-iceberg-configure-catalog-integration-vended-credentials>`を使用するため、EXTERNAL_VOLUMEパラメーターはCREATE ICEBERG TABLEステートメントから除外されます。

CREATE OR REPLACE ICEBERG TABLE my_iceberg_v3_table
  CATALOG = 'my_catalog_integration'
  CATALOG_TABLE_NAME = 'my_table'
  AUTO_REFRESH = TRUE;

サポートされていないSnowflake機能¶

以下のSnowflake機能は、Iceberg v3のこのプレビューではサポートされていません。

• 外部管理Icebergテーブルの追加専用ストリーム

• Snowflakeでのdbtプロジェクト

• スキーマ推論

• Snowpipe Streaming classic architecture

• SnowGov リージョン

• 外部カタログを使用するテーブルの場合、OBJECT、ARRAY、MAPのいずれかを含む構造化された型の列を持つIceberg v3テーブルを作成することができません。たとえば、CREATE ICEBERG TABLE … AS SELECT (CTAS)を使用して、構造化された型の列を持つ外部管理Iceberg v3テーブルを作成することができません。

  構造化された型の列を持つSnowflake管理Iceberg v3テーブルを作成できます。

• Snowflake管理Icebergテーブルのv2からv3へのインプレースアップグレード。これには、v2テーブルのクローン作成と、クローンのv3へのアップグレードが含まれます。

  重要

  Apache Sparkを使用して外部管理Icebergテーブルをv2からv3にアップグレードする場合は、DML操作など、新しいスナップショットを作成するコミットを使用する必要があります。それ以外の場合は、新しいスナップショットなしでテーブルプロパティで形式バージョンが更新された場合、新しいスナップショットが作成されるまで、テーブルのSnowflakeの手動および自動更新は失敗します。

  以下の例ではApache Sparkを使用して、外部管理Icebergテーブルをv2からv3にアップグレードします。

  ALTER TABLE table_name SET TBLPROPERTIES('format-version'='3');
  

  Copy

サポートされているSnowflake機能¶

:ref:`サポートされていないSnowflake機能<label-tables_iceberg_v3_unsupported_features>`セクションに記載されていない機能は、サポートされています。サポートされている機能には、以下のリストのものが含まれています。

サポートされていないIceberg v3機能¶

Iceberg v3仕様の以下の機能はサポートされていません。

• ネストされたバリアント

• パーティショニングとソートのための複数引数変換

• テーブル暗号化キー

• UNKNOWN データ型

v3 Icebergテーブルを作成する¶

次の例では、|iceberg-tm|仕様のv3に準拠したSnowflake管理の|iceberg-tm|テーブルを作成します。

CREATE ICEBERG TABLE my_v3_iceberg_table (
  record VARIANT,
  event_timestamp TIMESTAMP_LTZ(6)
)
  CATALOG = 'SNOWFLAKE'
  EXTERNAL_VOLUME = 'my_external_volume'
  BASE_LOCATION = 'my_iceberg_table'
  ICEBERG_VERSION = 3;

次の例では、リモートのIcebergRESTカタログを使用し、|iceberg-tm|仕様のv3に準拠した|iceberg-tm|テーブルを作成します。

CREATE ICEBERG TABLE my_v3_iceberg_table
  EXTERNAL_VOLUME = 'my_external_volume'
  CATALOG = 'my_rest_catalog_integration'
  CATALOG_TABLE_NAME = 'my_remote_table'
  AUTO_REFRESH = TRUE;

次の例では、列定義を持ち、|iceberg-tm|仕様のv3に準拠した書き込み可能なIcebergテーブルを:doc:`カタログリンクデータベース</user-guide/tables-iceberg-catalog-linked-database>`に作成します。

USE DATABASE my_catalog_linked_db;

USE SCHEMA 'my_namespace';

CREATE OR REPLACE ICEBERG TABLE my_iceberg_table (
  first_name string,
  last_name string,
  amount int,
  create_date date
)
  ICEBERG_VERSION = 3;

v3 Icebergテーブルへの書き込み¶

Snowflake管理および:ref:`外部管理<label-tables_iceberg_externally_managed_write_operations>`のIceberg v3テーブルへの書き込みは、DMLコマンドのINSERT、UPDATE、DELETE、MERGE、TRUNCATE TABLE、COPY INTOがサポートされています。

次の例では、|iceberg-tm|テーブル仕様のv3に準拠した|iceberg-tm|テーブルに行を挿入します。

INSERT INTO my_v3_iceberg_table (id, payload) VALUES (1, PARSE_JSON('{"name": "Alice", "age": 30}'));

次の例では、ファイルを|iceberg-tm|テーブル仕様のv3に準拠した|iceberg-tm|テーブルにロードします。

COPY INTO my_v3_iceberg_table
  FROM @my_json_stage
  FILE_FORMAT = 'my_json_format'
  MATCH_BY_COLUMN_NAME = CASE_SENSITIVE;

Snowpipeを使用したデータのロード¶

次の例では、Snowflake管理テーブルと外部管理テーブルの両方について、Iceberg v3テーブルのファイルからデータをロードします。

CREATE PIPE mypipe
  AUTO_INGEST = TRUE
  INTEGRATION = 'MYINT'
  AS
  COPY INTO snowpipe_db.public.my_v3_iceberg_table
  FROM @snowpipe_db.public.mystage
  FILE_FORMAT = (TYPE = 'JSON');

v3の動的Icebergテーブルを作成する¶

次の例では、v3 Snowflake管理のIcebergテーブルを動的テーブルの出力として書き込みます。

CREATE DYNAMIC ICEBERG TABLE my_dynamic_iceberg_v3_table (
    num_orders NUMBER(10,0),
    order_day
  )
  TARGET_LAG = '20 minutes'
  WAREHOUSE = my_warehouse
  EXTERNAL_VOLUME = 'my_external_volume'
  CATALOG = 'SNOWFLAKE'
  BASE_LOCATION = 'my_dynamic_iceberg_v3_table'
  ICEBERG_VERSION = 3
  AS
    SELECT
        COUNT(DISTINCT order_id)
        DATE_TRUNC('DAY', order_timestamp_ns) AS order_day
      FROM staging_v3_iceberg_table;

v3のIcebergテーブルをクエリする¶

次の例では、Snowflake管理または外部管理のIceberg v3テーブルをクエリします。

SELECT * FROM MY_DB.MY_SCHEMA.MY_ICEBERG_V3_TABLE;

Copy