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

Question

我有如下数据。

我需要如下输出。

我尝试如下构建转换。

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

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

Answer 1

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

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