Talend tJava

Talend tJava 组件允许我们编写自定义的 Java 代码。在此示例中，我们使用此 tJava 组件并编写简单的打印行 Java 语句。

Talend tJava 示例

从调色板将 tJava 组件拖放到作业设计中。从“组件”选项卡可以看出，它具有声明字符串变量并为其赋值的默认 Java 代码。

我将编写一个简单的打印行语句，包含欢迎消息，然后运行 tJava 作业。

从下面的屏幕截图中可以看到该消息。

tJava 示例 2

在此示例中，我们使用了之前创建的 tReplicate 作业。我们使用了子作业的 OnSubjectOk 触发器并将其连接到 tJava。

在 Talend tJava 组件代码中，我们正在打印 

• 从 tDBInput 传递的总行数。
• 在执行字符串替换后，插入到 tReplace 表中的行数。
• 在执行聚合后，插入到 Aggregate Row 表中的总行数。

为了获得这些结果，我们在 Java 代码中使用全局变量 NB_LINE（获取传递的行数）。

String x = "Total Input Rows = ";
x = x + globalMap.get("tDBInput_1_NB_LINE");
System.out.println(x);

String y = "Total Rows inserted in Talend_Replace Tabel = ";
y = y + globalMap.get("tDBOutput_1_NB_LINE");
System.out.println(y);

String z = "Total Rows inserted in Aggregate Row Tabel = ";
z = z + globalMap.get("tDBOutput_2_NB_LINE");
System.out.println(z);

String r = "Total Rejected Rows by Aggregate Row = ";
r = r + globalMap.get("tDBOutput_2_NB_LINE_REJECTED");
System.out.println(r);

运行 Java 作业后，您可以看到输出。