etl结合java的例子

1.新建Java测试类，导出Jar包，放在kettle目录中的libext文件中

  1. package test; 
  2. public class Test{ 
  3.     public static final String getMyName(String name){ 
  4.         return name+"12345"; 
  5.     } 
  6. }

2.抽数据--经过java处理--输出文件到桌面

  1. import test.Test; 
  2.  
  3. public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException 
  4. { 
  5.     Object[] r = getRow(); 
  6.     if (r == null) { 
  7.         setOutputDone(); 
  8.         return false; 
  9.     } 
  10.  
  11.     if (first) 
  12.     { 
  13.         first = false; 
  14.     } 
  15.  
  16.     // It is always safest to call createOutputRow() to ensure that your output row's Object[] is large 
  17.     // enough to handle any new fields you are creating in this step. 
  18.     //r = createOutputRow(r, outputRowSize); 
  19.      
  20.     /* TODO: Your code here. (See Sample) 
  21.      
  22.     / Get the value from an input field 
  23.     String foobar = get(Fields.In, "a_fieldname").getString(r); 
  24.  
  25.     foobar += "bar"; 
  26.      
  27.     // Set a value in a new output field 
  28.     get(Fields.Out, "output_fieldname").setValue(r, foobar); 
  29.  
  30.     */ 
  31.  
  32.     //调用jar 
  33.     String foobar = get(Fields.In, "ENAME").getString(r); //输入参数 
  34.     foobar += Test.getMyName("我是谁的水"); 
  35.     get(Fields.Out, "ENAME").setValue(r, foobar); 
  36.  
  37.      
  38.     //获取参数 
  39.      String AGEField = getParameter("AGE"); 
  40.      get(Fields.Out, "AGE").setValue(r, AGEField); //输出参数 
  41.      
  42.  
  43.     // Send the row on to the next step. 
  44.     putRow(data.outputRowMeta, r); 
  45.  
  46.     return true; 
  47. }

　　　　　　　　　　　　　　　　　　来源：http://programmer.blog.51cto.com/2859493/1164002

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/kongxc/p/6242321.html