Kettle的java脚本

Kettle的java脚本

import java.util.*;

private String str1;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException 
{
        Object[] r = getRow();
        // If the row object is null, we are done processing.
        if (r == null) {
            setOutputDone();
            return false;
        }
logMinimal("------------------------------------");
        String bb=get(Fields.In, "outputValue").getString(r);
        String output1 = to_Str_arr(bb);    //调用函数执行字符拆分，固然也能够直接拆分这里是顺带演示调用函数    

        // 建立输出行，
        //Object[] outputRow = createOutputRow(r, a1);
        
        get(Fields.Out, "outputValue").setValue(r, output1);
        putRow(data.outputRowMeta, r); // 输出行
        return true;


}

// 这里主要是将字符串转换为字符串数组，不过先将多个空格通过正则替换为一个
private String to_Str_arr(String str){
        String str1 = str;
        String str2 = str1.replaceAll("\\{", "");
        String str3 = str2.replaceAll("\\}", "");
        String str4 = str3.replaceAll("\\[", "{");
        String str5 = str4.replaceAll("\\]", "}");
        return str5.substring(3);
    }