数据库USERS表:
etl步骤:
（2）
（3）
其中java代码为:
import test.Test;
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
{
Object[] r = getRow();
if (r == null) {
setOutputDone();
return false;
}
if (first)
{
first = false;
}
// It is always safest to call createOutputRow() to ensure that your output row's Object[] is large
// enough to handle any new fields you are creating in this step.
//r = createOutputRow(r, outputRowSize);
/* TODO: Your code here. (See Sample)
/ Get the value from an input field
String foobar = get(Fields.In, "a_fieldname").getString(r);
foobar += "bar";
// Set a value in a new output field
get(Fields.Out, "output_fieldname").setValue(r, foobar);
*/
//获取参数
// String AGEField = getParameter("ID");
String ID = get(Fields.In, "ID").getString(r); //输入参数
get(Fields.Out, "ID").setValue(r, ID); //输出参数
//调用jar
String foobar = get(Fields.In, "NAME").getString(r); //输入参数
foobar += Test.getMyName("我是谁的水");
get(Fields.Out, "NAME").setValue(r, foobar);
//获取参数
// String AGEField = getParameter("ID");
//String ID = get(Fields.In, "ID").getString(r); //输入参数
get(Fields.Out, "aa").setValue(r, "xx"); //输出参数
// Send the row on to the next step.
putRow(data.outputRowMeta, r);
return true;
}
打成jar包丢到kettle目录下：
执行结果:
