Developerトランスフォーメーションガイド

前へ次へ

ソータートランスフォーメーションの例

顧客からのすべての注文に関する情報を含むデータベーステーブルPRODUCT_ORDERSがあります。

ORDER_ID	ITEM_ID	ITEM	QUANTITY	PRICE
43	123456	ItemA	3	3.04
41	456789	ItemB	2	12.02
43	000246	ItemC	6	34.55
45	000468	ItemD	5	0.56
41	123456	ItemA	4	3.04
45	123456	ItemA	5	3.04
45	456789	ItemB	3	12.02

PRODUCT_ORDERSでソータートランスフォーメーションを使用し、ORDER_IDをソートキーに、方向を降順に指定します。

データをソートした後、Data Integration Serviceはソータートランスフォーメーションから以下の行を渡します。

ORDER_ID	ITEM_ID	ITEM	QUANTITY	PRICE
45	000468	ItemD	5	0.56
45	123456	ItemA	5	3.04
45	456789	ItemB	3	12.02
43	123456	ItemA	3	3.04
43	000246	ItemC	6	34.55
41	456789	ItemB	2	12.02
41	123456	ItemA	4	3.04

注文ごとの合計金額と数量を特定する必要があります。ソータートランスフォーメーションの結果をアグリゲータトランスフォーメーションへの入力として使用できます。パフォーマンスを向上させるには、アグリゲータトランスフォーメーションでソート済み入力を使用します。

［ソート済み入力］オプションを使用しない場合、Data Integration Serviceは読み込みと並行して集計計算を実行します。すべての集計計算が正確に実行されるように、Data Integration Serviceはソース全体の読み込みが完了するまで各グループのデータを格納しておきます。［ソート済み入力］オプションを使用する場合、前もってデータを正しくソートしておかないと、予期しない結果が生じます。

アグリゲータトランスフォーメーションでポート別のORDER_IDグループがあり、ソート済み入力オプションが選択されているとします。ソータートランスフォーメーションからデータを渡すと、アグリゲータトランスフォーメーションはORDER_IDをグループ化して、注文ごとの合計金額を計算します。