Icebergテーブルをマージ

このシナリオの最後のステップは、marketing_iceberg Icebergテーブルのデータをcustomers_iceberg Iceberg Icebergテーブルにマージすることです。

このタスクについて

このタスクでは、Mergingサブジョブが使用されます。

手順

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

タスクの結果

結果は、ジョブの[Execution] (実行)コンソールに表示されます。マージ前の結果は117、マージ後の結果は158で、Updatingサブジョブからの以前の結果と一致することがわかります。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください