Datastage java transformer stage

import java.io.BufferedReader;
import java.io.InputStreamReader;

import com.ibm.is.cc.javastage.api.Processor;
import com.ibm.is.cc.javastage.api.StageData;

public class MyJavaTransformer implements Processor {
    @Override
    public void process(StageData[] inputs, StageData[] outputs) throws Exception {
        // 获取输入数据流
        StageData input = inputs[0]; // 假设只有一个输入链接

        // 使用输入数据的流创建读取器
        BufferedReader reader = new BufferedReader(new InputStreamReader(input.getInputStream()));

        String line;
        while ((line = reader.readLine()) != null) {
            // 对每一行数据进行处理，这里仅示例将数据转换为大写
            String processedLine = line.toUpperCase();

            // 将处理后的数据写入输出链接
            outputs[0].getOutputStream().write((processedLine + "\n").getBytes());
        }

        // 关闭流和资源
        reader.close();
        input.close();
        outputs[0].close();
    }
}