java - java中的Pentaho Kettle程序按列合并多个csv文件

Question

我有两个 csv 文件employee.csv 和loan.csv。

在employee.csv中，我有四列，即empid(Integer)、name(String)、age(Integer)、education(String)。

在loan.csv中，我有三列，即loan(Double)、balance(Double)、empid(Integer)。

现在，我想通过 empid 列将这两个 csv 文件合并为一个 csv 文件。因此在 result.csv 文件中，列应该是，

• empid(整数)，
• 名称(字符串)，
• 年龄(整数)，
• 教育(字符串)，
• 贷款(双倍)，
• 余额(双)。

而且我只能通过使用Java中的kettle api程序来实现这一点。有人可以帮我吗？

Answer 1

首先，您需要创建一个水壶转换，如下所示:

1. 采取两个“CSV 输入步骤”，一个用于employee.csv，另一个用于loan.csv
2. 将输入跳转到“Stream Lookup”步骤并使用“emplid”进行查找
3. 最后一步:获取文本文件输出以生成 csv 文件输出。

我已将 ktr 代码放在 here 中.

其次，如果您想使用Java执行此转换，我建议您阅读this博客。我已经解释了如何使用 Java 执行 .ktr/.kjb 文件。

<小时/>

加分:

如果需要将 csv 文件的名称作为参数从 Java 代码传递，您可以通过添加以下代码来实现:

  trans.setParameterValue(parameterName, parameterValue);

其中 parameterName 是某个变量名称parameterValue 是文件或位置的名称。

我已经将文件名作为我共享的水壶代码中的参数。

希望有帮助:)