计算 Kettle 转换中过滤的行数

Count Filtered Rows in Kettle Transformation

可能有一个简单的解决方案——我只是找不到它:

在 kettle 转换中,行从一些数据库 table 中读取,通过一些过滤步骤传递,最后写入其他数据库 table。过滤步骤消除了不匹配的行。

在此过程中,我想计算 "good" 和 "bad" 行并将这两个结果传递给调用作业以发送电子邮件,例如

<n> rows in total (<g> good / <b> bad)

PS: 使用全局变量并在 JavaScript 步中增加它们不起作用...(多线程?)

您可以使用 GroupBy 步骤和 "Number of rows (without field argument)" 聚合计算每个分支中的行数,然后您可以使用这些计算值根据需要设置变量。