在五旬节水壶变换中合并2行

Question

我的KTR是：

​

Json输入给出的MongoDB如下：

{ "_id“：{ "$oid”："525cf3a70fafa305d949ede0"}、“资产”："RO2500AS1“、”盐拒绝“："82%”、“盐通道”："18%“、”恢复“："56.33%”、“集中系数”："2.3“、”状态“：”关键“、”流量警报“：”高流量“}

和一个返回2行的表输入：

​

​

在StreamLookUp步骤中，查找键被配置为资产= AssetName

我的最后输出是返回两个jsons：

{“数据”：{“估计费用”：“15美元”、"AssetName":"RO2500AS1“、”描述“：”泵维护“、”索引“：1、"json":"{”_id\：{“$oid\”：\“525cf3a70fafa305d949ede0}、\”资产“：\"RO2500AS1\”、\“盐拒绝”：\“82%”，\“盐通道”：“18%”、“恢复”：“56.33%”、“浓缩系数”：“2.3”、“状态”：\“临界”、\“流量警报”：\\“高流量”}、“类型”：“服务”、“DeadLine”：“2013年11月13日”}} {“数据”：{“估计费用”：“35美元”、"AssetName":"RO2500AS1“、”描述“：”热传感器“、”索引“：2、"json":"{”_id\：{“$oid\”：\“525cf3a70fafa305d949ede0”}、\“资产”：\"RO2500AS1\“、\”拒绝盐“：\”82%“，“盐通道”：“18%”、“恢复”：“56.33%”、“浓缩系数”：“2.3”、“状态”：\“临界”、\“流量警报”：\\“高流量”}、“类型”：“替换”、“DeadLine”：“2013年11月26日”}}

我希望我的最后一个JSON输出合并显示结果，如下所示：

{“数据”：{“估计费用”：“15美元”、"AssetName":"RO2500AS1“、”描述“：”水泵维修“、”索引“：1、”类型“：”服务“、”DeadLine“：”2013年11月13日“}、{”估计费用“：”35美元“、"AssetName":"RO2500AS1”、“描述”：“热传感器”、“指数”：2、“类型”：“替换”、“DeadLine”：“2013年11月26日”} "json":{ "_id“："525cf3a70fafa305d949ede0"}、”资产“："RO2500AS1”、“盐拒绝”："82%“、”盐通道“："18%”、“恢复”："56.33%“、”集中系数“："2.3”、“状态”：“关键”、“流量警报”：“高流量”}

这意味着合并2行。

有人能帮忙吗？

Answer 1

您可以在表输入之后使用MergeJoin。这将合并Mysql输出行中的行，并且只有一个JSON作为输出.

Answer 2

您可能希望将合并步骤用于您的目的。不要忘记对输入流进行排序。

注意:在此步骤中，预期行将在指定的键字段上排序。当使用排序步骤时，这很好。当您在PDI之外对数据进行排序时，可能会遇到内部区分大小写/不敏感标志的问题。