尝试在 pentaho 数据集成中构建日志记录机制

问题描述

我有如下数据。

enter image description here

我需要如下输出

enter image description here

我尝试构建如下转换。

enter image description here

在这里,如果我运行转换,我会得到如下输出

enter image description here

有人可以建议 PDI 中的组件以获得正确的输出吗?

解决方法

可能,在 SV 和 SV2 步骤之后,您需要两个“Memory Group by”步骤,然后是 MPN_code 的 Merge Join。

我不知道你是否正在实现你想要的。请记住,在转换中,所有步骤都是同时初始化的,因此根据您计算 Starttime 和 Endtime 的方式,您可能会为所有行获得相同的时间,因为它计算为第一行到达流的时间的步骤。