Icebergテーブルをマージ
このシナリオの最後のステップは、marketing_iceberg Icebergテーブルのデータをcustomers_iceberg Iceberg Icebergテーブルにマージすることです。
このタスクについて
このタスクでは、Mergingサブジョブが使用されます。
手順
-
mergeと呼ばれるtIcebergMergeの[Basic settings] (基本設定)ビューから、次のようにパラメーターを設定します:
- [Connection] (接続)ドロップダウンリストから、使用する接続コンポーネントを選択します。この例では、tIcebergConnection_1です。
- [Source type] (ソースタイプ)ドロップダウンリストから、マージアクションを実行するためのデータ取得方法を選択します。この例では、Tableです。
- [Source table name] (ソーステーブル名)パラメーターに、データの取得元としたいIcebergテーブルの名前を入力します。この例では、marketing_icebergです。
- [Source alias] (ソースエイリアス)パラメーターで、ソーステーブルで使用するエイリアスを入力します。この例では、Mです。
- [Target table name] (ターゲットテーブル名)パラメーターに、マージを実行したいIcebergテーブルの名前を入力します。この例では、customers_icebergです。
- [Target alias] (ターゲットエイリアス)パラメーターで、ターゲットテーブルで使用するエイリアスを入力します。この例では、Tです。
- [Merge ON] (マージON)パラメーターに、ソーステーブルとターゲットテーブルの結合に使用するブール式を入力します。この例では、M.customer_id=C.customer_idです。これによって、marketing_icebergのcustomer_idデータをcustomers_icebergにマージできるようになります。
- [When matched update] (一致したらアップデート)チェックボックスをオンにすると、WHEN MATCHED THEN UPDATE SETステートメントを実行し、[Set clauses] (句リストを設定)パラメーターに句のブール式を入力できます。この例では、membership_type=M.memberhsip_typeです。これによって、membership_typeデータでマージを実行できるようになります。
- 他のパラメーターはそのままにしておきます。
-
count gold membersと呼ばれる2つのtIcebergInputの[Basic settings] (基本設定)ビューで、次のようにパラメーターを設定します:
- [Sql query] (SQLクエリー)フィールドで、実行するSQLクエリーを入力します。この例では、"SELECT count (*) as total from marketing_iceberg where membership_type='Gold'"です。これによって、ゴールドメンバーシップを持つメンバー全員をカウントできるようになります。
- [Connection] (接続)ドロップダウンリストから、使用する接続コンポーネントを選択します。この例では、tIcebergConnection_1です。