Apache Iceberg™ テーブルの管理¶

テーブルをクエリする¶

Icebergテーブルにクエリを実行するには、ユーザーに次の権限を付与または継承させる必要があります。

• テーブルを含むデータベースとスキーマに対するUSAGE権限。

• テーブルに対するSELECT権限。

SELECT ステートメントを使用してIcebergテーブルにクエリを実行できます。例:

SELECT col1, col2 FROM my_iceberg_table;

DML コマンドを使用する¶

Snowflakeをカタログとして使用するIcebergテーブルは、以下を含む完全な データ操作言語（DML）コマンド をサポートしています。

• INSERT

• MERGE

• UPDATE

• DELETE

• TRUNCATE TABLE

Snowflake管理テーブルでは、 COPY INTO <テーブル> や Snowpipe などの機能を使用した効率的な一括ロードもサポートしています。詳細については、 Apache Iceberg™ テーブルへのデータのロード をご参照ください。

INSERT INTO store_sales VALUES (-99);

UPDATE store_sales
  SET cola = 1
  WHERE cola = -99;

DML の変更のスナップショットを生成する¶

Snowflakeをカタログとして使用するテーブルの場合、Snowflakeは自動的にIcebergメタデータを生成します。Snowflakeはメタデータを外部ボリュームの metadata という名前のフォルダに書き込みます。metadata フォルダーを見つけるには、 データとメタデータのディレクトリ をご参照ください。

あるいは、 SYSTEM$GET_ICEBERG_TABLE_INFORMATION 関数を呼び出して、新しい変更に対してIcebergメタデータを生成することもできます。

Snowflakeで管理されていないテーブルの場合、この関数は最新のリフレッシュされたスナップショットに関する情報を返します。

例:

SELECT SYSTEM$GET_ICEBERG_TABLE_INFORMATION('db1.schema1.it1');

出力:

+-----------------------------------------------------------------------------------------------------------+
| SYSTEM$GET_ICEBERG_TABLE_INFORMATION('DB1.SCHEMA1.IT1')                                                   |
|-----------------------------------------------------------------------------------------------------------|
| {"metadataLocation":"s3://mybucket/metadata/v1.metadata.json","status":"success"}                         |
+-----------------------------------------------------------------------------------------------------------+

行レベル削除の使用¶

Snowflakeは、行レベルの削除を使用したテーブルのクエリと、行レベルの削除を使用したテーブルへの書き込みをサポートしています。

ターゲットファイルサイズの設定¶

SparkやTrinoなどの外部Icebergエンジンのクエリパフォーマンスを改善するために、Snowflakeで管理されるIcebergテーブルと 書き込みサポート付きの外部で管理されるIcebergテーブル の両方のターゲットファイルサイズを構成できます。特定のサイズ（16MB、32MB、64MB、または 128MB）を設定するか、AUTO オプションを使用できます。 AUTO の動作は、テーブルの種類によって異なります。

• Snowflake 管理テーブル: AUTO は、サイズ、DML パターン、取り込みワークロード、クラスタリング構成などのテーブル特性に基づいて、Snowflakeがテーブルのファイルサイズを選択することを指定します。Snowflakeは、Snowflakeでの読み取りと書き込みパフォーマンスを向上させるために、ファイルサイズを16 MB を起点として自動的に調整します。

• 外部管理テーブル: AUTO は、Snowflakeがより大きなファイルサイズに積極的にスケーリングすることを指定します。

Icebergテーブルを作成するときに、ターゲットファイルサイズを設定することも、ALTER ICEBERG TABLE コマンドを実行して既存のIcebergテーブルのターゲットファイルサイズを変更することもできます。Snowflakeはテーブル用にParquetファイルを書き込むときに、ファイルサイズがターゲットサイズに近くなるように保とうとします。

ターゲットファイルサイズを設定すると、Snowflakeはすぐに新しいデータ操作言語（DML）操作に対して、すぐにより大きなファイルの作成を開始します。Snowflakeのテーブルメンテナンス操作は、ターゲットファイルサイズに従って既存のテーブルファイルを非同期的に変更します。

次の例では、Snowflake管理テーブルに対して、TARGET_FILE_SIZE を使用してターゲットファイルサイズを128 MB に設定しています。

CREATE ICEBERG TABLE my_iceberg_table (col1 INT)
  CATALOG = 'SNOWFLAKE'
  EXTERNAL_VOLUME = 'my_external_volume'
  BASE_LOCATION = 'my_iceberg_table'
  TARGET_FILE_SIZE = '128MB';

あるいは、既存のテーブルに対して TARGET_FILE_SIZE プロパティを設定するには、ALTER ICEBERG TABLE を使用します。

ALTER ICEBERG TABLE my_iceberg_table
  SET TARGET_FILE_SIZE = '32MB';

テーブルの TARGET_FILE_SIZE プロパティの値を確認するには、SHOW PARAMETERS コマンドを使用します。

SHOW PARAMETERS LIKE 'target_file_size' FOR my_iceberg_table;

Snowflake管理のIcebergテーブルのテーブル最適化¶

テーブルの最適化では、Snowflakeが管理するIcebergテーブルのパフォーマンスを改善してストレージコストを削減するためのメンテナンスを自動的に実行します。

Snowflakeは、以下の表にまとめたIcebergテーブル最適化機能をサポートしています。

_{[1] 他のテーブル最適化機能とは異なり、自動クラスタリングは独立した機能として別途請求されます。}

外部カタログを使用するテーブルの維持¶

外部カタログを使用するIcebergテーブルに対してメンテナンス操作を実行できます。

メンテナンス操作は以下の通り：

• 期限切れ間近のスナップショット

• 古いメタデータファイルの削除

• データファイルのコンパクト化

Snowflakeで管理されていないIcebergテーブルのメンテナンスについては、Apache Icebergドキュメントの メンテナンス をご参照ください。

テーブルのメタデータをリフレッシュする¶

外部Icebergカタログを使用する場合、 ALTER ICEBERG TABLE ... REFRESH コマンドを使用してテーブル メタデータをリフレッシュできます。テーブルのメタデータを更新すると、メタデータが最新のテーブルの変更と同期されます。

ALTER ICEBERG TABLE my_iceberg_table REFRESH;

ALTER ICEBERG TABLE my_iceberg_table SET AUTO_REFRESH = TRUE;

ALTER ICEBERG TABLE my_iceberg_table REFRESH 'metadata/v1.metadata.json';

ストレージメトリックの取得¶

Snowflakeでは、Icebergテーブルの保管コストをお客様のアカウントに請求することはありません。しかし、 Snowflake Information Schema スキーマまたは Account Usage スキーマの TABLE_STORAGE_METRICS ビューと TABLES ビューをクエリすることで、Icebergテーブルがどれだけのストレージを使用しているかを追跡することができます。

次の例のクエリは、 ACCOUNT_USAGE.TABLE_STORAGE_METRICS ビューと ACCOUNT_USAGE.TABLES ビューを結合し、 TABLES.IS_ICEBERG 列でフィルタリングします。

SELECT metrics.* FROM
  snowflake.account_usage.table_storage_metrics metrics
  INNER JOIN snowflake.account_usage.tables tables
  ON (
    metrics.id = tables.table_id
    AND metrics.table_schema_id = tables.table_schema_id
    AND metrics.table_catalog_id = tables.table_catalog_id
  )
  WHERE tables.is_iceberg='YES';

データ圧縮の設定¶

データベース、スキーマ、またはテーブルを作成するときに、Snowflake管理Icebergテーブルにデータ圧縮を設定できます。既存のデータベース、スキーマ、またはテーブルの設定を変更するには、 ALTER コマンドを実行します。また、アカウントレベルでデータ圧縮を設定するには、ALTER ACCOUNT コマンドを使用することもできます。データ圧縮の詳細については、 データ圧縮 をご参照ください。

次の例では、ENABLE_DATA_COMPACTIONを使用して、 Snowflake管理テーブルのデータ圧縮を無効にします。

CREATE ICEBERG TABLE my_iceberg_table (col1 INT)
  CATALOG = 'SNOWFLAKE'
  EXTERNAL_VOLUME = 'my_external_volume'
  BASE_LOCATION = 'my_iceberg_table'
  ENABLE_DATA_COMPACTION = FALSE;

または、既存のテーブルに対して無効化するには、:doc:`/sql-reference/sql/alter-iceberg-table`を使用します。

ALTER ICEBERG TABLE my_iceberg_table
  SET ENABLE_DATA_COMPACTION = FALSE;

詳細については、次をご参照ください。

• ENABLE_DATA_COMPACTION

• ALTER ACCOUNT

• CREATE DATABASE

• ALTER DATABASE

• CREATE SCHEMA

• ALTER SCHEMA

• CREATE ICEBERG TABLE （IcebergカタログとしてのSnowflake）

• ALTER ICEBERG TABLE