stage 内の Parquet ファイルをクエリする

構文

• 行を Variants としてクエリ
• 名前でカラムをクエリ
• メタデータのクエリ

チュートリアル

ステップ 1. 外部 stage を作成する

Parquet ファイルが保存されている独自の S3 バケットと認証情報を使用して外部 stage を作成します。

CREATE STAGE parquet_query_stage
URL = 's3://load/parquet/'
CONNECTION = (
    ACCESS_KEY_ID = '<your-access-key-id>'
    SECRET_ACCESS_KEY = '<your-secret-access-key>'
);

ステップ 2. カスタム Parquet ファイル形式を作成する

CREATE FILE FORMAT parquet_query_format TYPE = PARQUET;

• Parquet ファイル形式のその他のオプションについては、Parquet ファイル形式オプション を参照してください。

ステップ 3. Parquet ファイルをクエリする

カラム名を使用してクエリします。

SELECT *
FROM @parquet_query_stage
(
    FILE_FORMAT => 'parquet_query_format',
    PATTERN => '.*[.]parquet'
);

パス式を使用してクエリします。

SELECT $1
FROM @parquet_query_stage
(
    FILE_FORMAT => 'parquet_query_format',
    PATTERN => '.*[.]parquet'
);

メタデータを使用してクエリする

METADATA$FILENAME や METADATA$FILE_ROW_NUMBER などのメタデータカラムを含めて、stage から Parquet ファイルを直接クエリします。

SELECT
    METADATA$FILENAME,
    METADATA$FILE_ROW_NUMBER,
    *
FROM @parquet_query_stage
(
    FILE_FORMAT => 'parquet_query_format',
    PATTERN => '.*[.]parquet'
);