java - 处理 Kettle 步骤的多个输入

Question

我正在尝试创建一个有两个输入的步骤。两者的格式应该相同。我需要使用这两个输入流进行处理并输出一个流。

下面是我迄今为止在 processRow() 中的代码:

List<StreamInterface> infoStreams = meta.getStepIOMeta().getInfoStreams();

data.oneRowSet = findInputRowSet(infoStreams.get(0).getStepname());
data.twoRowSet = findInputRowSet(infoStreams.get(1).getStepname());

如果是第一行，并且所有行都是以下内容:

data.one = getRowFrom(data.oneRowSet);
data.two = getRowFrom(data.twoRowSet);

if (data.one == null && data.two == null) {
      setOutputDone();
      return false;
}

但是，在 data.oneRowSet = findInputRowSet(infoStreams.get(0).getStepname()); 行上，我收到以下错误:无法找到从 [null] 读取的源步骤。

您对此的意见将会非常有帮助。谢谢。

编辑:我在此处添加了示例转换和我的步骤的源代码:https://github.com/adeydas/KettleMultipleStreams/tree/develop

Answer 1

我似乎找到了解决办法。我在这里写了一个小“操作方法”:http://abhis.ws/display/KKB/Kettle+transformation+step+with+multiple+input+streams代码位于 GitHub 上:https://github.com/adeydas/KettleMultipleStreams .