处理多个输入到水壶步骤

Abhishek Dey Das 发表于 Dev

阿比舍克·戴伊·达斯

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

下面是我到目前为止在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());，出现以下错误：The source step to read from [null] couldn't be found。

您对此的投入将非常有帮助。谢谢。

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

阿比舍克·戴伊·达斯

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

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。