Talend ETL - 提取插入到 table 中的新记录

Question

嗨，

我创建了一个 Talend ETL 作业，它使用对 tmap 的查询将记录插入到名为 "loan_grouping" 的 table 中。我在 tmap 中使用查找 "loan_grouping" table 来提取现有记录。

我需要的是一种只提取新创建和插入的记录的方法。我在网上找到了指南，其中显示了如何使用 tmap 中的 Catch 查找内部连接拒绝选项提取被拒绝的记录 - 但我需要相反的方法 - 我需要显示成功的记录。

我在tmap中使用的表达式是：

!row1.GROUP_REFERENCE.equals(row3.GROUP_REFERENCE)

但它仍然只给我被拒绝的记录。我还附上了一些截图。如果有人能提供帮助，我将不胜感激！

Answer 1

您对 tMap 组件的内部连接和过滤器感到困惑，据我了解，您不需要过滤器，只需要内部连接及其接受和拒绝的数据，因此您需要删除条件 !row1.GROUP_REFERENCE.equals(row3.GROUP_REFERENCE)从右上角的过滤器框中。由于此 tMap 中存在内部连接，您无法获取输出中的所有记录，我们可以拥有匹配内部连接和拒绝记录的记录，因此我们可以在此 tmap 之后使用 tUnite 合并两个输出并取回所有数据或使用初始来源：

                       lookup
                          |
tReplicate------(main)---tmap-------- (records that already have ref)
         \                  \
          \                  rejected (new records)
           \
            (all records)

Talend ETL - 提取插入到 table 中的新记录

Talend ETL - Extract new records being inserted into the table

mysql

etl

talend