Talend可以使用Java代码来处理数据转换。以下是一个简单的例子：
假设你有一个包含以下列的CSV文件：
Name,Age,Gender
John,25,Male
Jane,30,Female
你需要将它转换为以下格式：
{"records": [{"name": "John","age": 25,"gender": "Male"},{"name": "Jane","age": 30,"gender": "Female"}]
}
你可以使用以下步骤来完成此转换：
-
创建一个Talend Job，并添加一个
tFileInputDelimited组件来读取CSV文件。 -
添加一个
tJavaRow组件，将其连接到tFileInputDelimited组件。 -
在tJavaRow组件中使用以下代码：
-
// 获取输入行 String name = input_row.Name; int age = Integer.parseInt(input_row.Age); String gender = input_row.Gender;// 将数据格式化为JSON字符串 String json = String.format("{\"name\": \"%s\", \"age\": %d, \"gender\": \"%s\"}", name, age, gender);// 将JSON字符串写入上下文 output_row.json = json; -
添加一个
tAggregateRow组件，将其连接到tJavaRow组件。在tAggregateRow组件中，设置Aggregate type为First，并创建一个名为records的新列。 -
在
tAggregateRow组件中，使用以下代码将多行数据聚合为一个JSON对象：
// 创建一个空的JSON对象
JSONObject jsonObject = new JSONObject();
JSONArray recordsArray = new JSONArray();// 循环遍历每行数据
for (int i = 0; i < input_rows.size(); i++) {// 将每行数据转换为JSON对象JSONObject record = new JSONObject(input_rows.get(i).json);// 添加到records数组recordsArray.put(record);
}// 将records数组添加到JSON对象
jsonObject.put("records", recordsArray);// 将JSON对象写入上下文
output_row.json = jsonObject.toString();
-
添加一个
tFileOutputJSON组件，将其连接到tAggregateRow组件。设置目标文件路径。 -
运行作业。在目标文件中，你会得到以下JSON：
{"records": [{"name": "John","age": 25,"gender": "Male"},{"name": "Jane","age": 30,"gender": "Female"}]
}
这只是一个简单的例子。你可以在tJavaRow组件中使用更复杂的Java代码来处理数据转换，并使用其他组件来完成不同的任务。
