Talend tRunJob

在本文中,我们使用此 Talend tRunJob 组件来演示父子作业。此示例可帮助您了解 tBufferOutput,以及如何将数据从父作业读取到子作业。

为了演示 Talend tRunJob,我们使用了之前创建的 tSortRow 示例。在这里,我们使用 tDBInput 选择客户表,并使用 tSortRow 按以下顺序对记录进行排序。我们没有将输出保存在表中,而是使用 tBufferOutput 来缓冲数据。

为了显示数据,我将连接 tLogRow 到 tBufferOutput 并运行 tRunJob。

为 tRunJob 创建 Talend 父作业

我们创建了另一个作业,然后将 tRunJob 组件添加到设计器窗口。

Add Talend tRunJob to workflow for the parent job

以下屏幕截图显示了可用选项。请单击“浏览作业” (…) 按钮以选择先前设计的作业。在此,我们选择了 Data_Sorting_Parent_Job。

Choose the Parent Job from the Repository Content

首先,单击“复制子作业模式”以将选定作业中的列添加或加载到当前作业。接下来,单击“编辑模式”以检查并添加/删除不需要的列。

请根据您的需要更改版本。接下来,添加上下文参数(如果有)。

Configure tRunJob to run parent job

在这里,我们添加了 tAggregateSortedRow 并将其连接到 Talend tRunJob。通常,tAggregateSortedRow 需要排序数据,而我们的子作业使用 tSortRow 组件对这些行进行了排序。在 tAggregateSortedRow 中,我们按职业对列进行了分组并执行了一些聚合。

Configure aggregate sorted rows

我将添加 tLogRow 来向您显示聚合输出。为此,将 tLogRow 添加到工作流中,并将其主行连接到 tAggregateSortedRow。接下来,在 tLogRow 组件选项卡中,选择表选项。

请运行 tRunJob 查看结果。

Run tRunJob to execute parent job