各マッピングには、1つ以上のパイプラインが含まれています。パイプラインは、読み取りトランスフォーメーションと、読み取りトランスフォーメーションからデータを受信するすべてのトランスフォーメーションで構成されています。 データ統合サービスは、マッピングパイプラインをパイプラインステージに分けてから、各パイプラインステージの抽出、トランスフォーメーション、およびロードを並行して実行します。

パーティションポイントはパイプラインの境界をマークし、パイプラインをステージに分割します。どのマッピングパイプラインに対しても、データ統合サービスは、読み取りトランスフォーメーションの後、および書き込みトランスフォーメーションが複数のパイプラインステージを作成する前に、パーティションポイントを追加します。

各パイプラインステージは以下のいずれかのスレッドを実行します。

以下の図に、読み取りパイプラインステージ、トランスフォーメーションパイプラインステージ、および書き込みパイプラインステージに区切られたマッピングを示します。

パイプラインには3つのステージが含まれるため、データ統合サービスでは3セットの行を同時に処理してマッピングのパフォーマンスを最適化することができます。例えば、読み取りスレッドが3番目の行セットを処理している間、トランスフォーメーションスレッドは2番目の行セットを処理し、書き込みスレッドは1番目の行セットを処理します。

以下の表に、複数のスレッドが3セットの行を同時に処理する方法を示します。

マッピングパイプラインに複雑な計算を実行するトランスフォーメーションが含まれている場合、トランスフォーメーションパイプラインステージの処理には時間がかかる可能性があります。パフォーマンスを最適化するには、一部のトランスフォーメーションが追加のトランスフォーメーションパイプラインステージを作成する前に、データ統合サービスがパーティションポイントを追加します。