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

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

我有如下数据。

我需要如下输出。

我尝试构建如下转换。

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

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

解决方法

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

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