Developer 转换指南

上一个下一个

联接同一管道的两个分支

从同一源联接数据时，可以创建该管道的两个分支。

使管道产生分支时，必须至少将映射输入和联接器转换之间的转换添加到管道的一个分支中。必须联接已排序数据并为已排序输入配置联接器转换。

例如，具有使用以下端口的源：

Employee

部门

销售总额

在目标中，希望查看生成的销售额高于部门平均销售额的员工。要执行该操作，请使用以下转换创建映射：

排序器转换。对数据进行排序。

已排序汇总器转换。计算销售数据的平均值并按部门进行分组。执行此汇总时，将丢失单个员工的数据。要维护员工数据，必须将管道的分支传递给汇总器转换，并将具有相同数据的分支传递给联接器转换以维护原始数据。联接管道的两个分支时，将联接汇总数据与原始数据。

已排序联接器转换。联接已排序汇总数据与原始数据。

筛选器转换。比较平均销售数据和每个员工的销售数据，并筛选销售额低于上述平均值的员工。

Employees_West 源

管道分支 1

管道分支 2

已排序联接器转换

筛选销售额低于上述平均值的员工

如果联接器转换从一个分支接收到数据的时间远远晚于从另一个分支接收到数据的时间，则联接这两个分支可能会降低性能。联接器转换将缓存第一个分支中的所有数据，并在缓存已满时将其写入磁盘。然后，联接器转换接收第二个分支中的数据时，必须从磁盘中读取数据。

发送反馈