kettle入門篇(二)-java代碼組件的使用

java代碼組件的使用

連接資源庫(kù)(可參考入門篇(一))

新建轉(zhuǎn)換

需求:根據(jù)身份證确徙,計(jì)算得出年齡和出生年月。這里我們用生成記錄組件,來模擬從表中獲取到數(shù)據(jù)。

生成記錄組件:

kettle-java-code-生成記錄組件.png

kettle-java-code-配置生成記錄.png

配置java代碼


kettle-java-code-java代碼組件.png

kettle-java-code-生成processRow方法.png
// 生成的代碼片段
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
  if (first) {
    first = false;

    /* TODO: Your code here. (Using info fields)

    FieldHelper infoField = get(Fields.Info, "info_field_name");

    RowSet infoStream = findInfoRowSet("info_stream_tag");

    Object[] infoRow = null;

    int infoRowCount = 0;

    // Read all rows from info step before calling getRow() method, which returns first row from any
    // input rowset. As rowMeta for info and input steps varies getRow() can lead to errors.
    while((infoRow = getRowFrom(infoStream)) != null){

      // do something with info data
      infoRowCount++;
    }
    */
  }

  Object[] r = getRow();

  if (r == null) {
    setOutputDone();
    return 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, data.outputRowMeta.size());

  /* 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);

  */
  // Send the row on to the next step.
  putRow(data.outputRowMeta, r);

  return true;
}

點(diǎn)擊main可以生成java代碼的模板域醇。如果需要修改,我們只要在putRow(data.outputRowMeta, r);寫自己的邏輯代碼即可蓉媳。
根據(jù)我們的需求譬挚,我們需要根據(jù)身份證計(jì)算年齡和生日。所以接下來酪呻,我們只要在它標(biāo)記的TODO: Your code here. (See Sample)開始編寫自己的邏輯代碼即可减宣。
首先需要獲取從生成記錄中獲取到我們的身份證信息。

kettle-java-code-getIdCard.png

編寫邏輯代碼

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
 if (first) {
   first = false;
 }

 Object[] r = getRow();

 if (r == null) {
   setOutputDone();
   return false;
 }

 r = createOutputRow(r, data.outputRowMeta.size());
   //身份證
   String idCard = get(Fields.In, "idCard").getString(r);
   // 判斷身份證是否為空(這里暫時(shí)只做為空校驗(yàn)玩荠,暫不做正則)
   // 321111199501010101
   SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
   try {
     if(null != idCard && idCard.length() == 18){
       String substring = idCard.substring(6, 14);
       Date parse = format.parse(substring);
       if(parse != null){
         Calendar start = Calendar.getInstance();
         Calendar end = Calendar.getInstance();
         start.setTime(parse);
         end.setTimeInMillis(System.currentTimeMillis());
         long age = end.get(Calendar.YEAR) - start.get(Calendar.YEAR);
         get(Fields.Out, "age").setValue(r, age);
         get(Fields.Out, "birth").setValue(r, parse);
           logBasic("age: " + age);
           logBasic("birth: " + parse);
       }
     }else{
         throw new Exception("身份證號(hào)不規(guī)范蚪腋!無法解析"); 
     }  
   } catch (Exception e) {
     e.printStackTrace();
   }
 putRow(data.outputRowMeta, r);

 return true;
}

運(yùn)行轉(zhuǎn)換

kettle-java-code-result.png

注意點(diǎn):

  1. 獲取變量get(Fields.In, "idCard").getString(r);根據(jù)變量類型的不同丰歌,getString需要變換姨蟋。

  2. 設(shè)置變量get(Fields.Out, "birth").setValue(r, parse);

  3. 日志輸出logBasic("age: " + age);

    kettle-java-code-log.png
  1. 導(dǎo)包屉凯;import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date;需要java環(huán)境或者Lib下的jar包里的類,包括kettle自帶的類都行

  2. 輸出變量眼溶,如果輸入與輸出的變量一樣悠砚,可以不寫。如果不一樣堂飞,需要在下面填寫新的變量灌旧,如圖所示:

kettle-java-code-new-var.png
  1. 最后不要忘記putRow(data.outputRowMeta, r);及return true;
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市绰筛,隨后出現(xiàn)的幾起案子枢泰,更是在濱河造成了極大的恐慌,老刑警劉巖铝噩,帶你破解...
    沈念sama閱讀 216,651評(píng)論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件衡蚂,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡骏庸,警方通過查閱死者的電腦和手機(jī)毛甲,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,468評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來具被,“玉大人玻募,你說我怎么就攤上這事∫蛔耍” “怎么了七咧?”我有些...
    開封第一講書人閱讀 162,931評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)叮叹。 經(jīng)常有香客問我艾栋,道長(zhǎng),這世上最難降的妖魔是什么衬横? 我笑而不...
    開封第一講書人閱讀 58,218評(píng)論 1 292
  • 正文 為了忘掉前任裹粤,我火速辦了婚禮,結(jié)果婚禮上蜂林,老公的妹妹穿的比我還像新娘遥诉。我一直安慰自己,他們只是感情好噪叙,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,234評(píng)論 6 388
  • 文/花漫 我一把揭開白布矮锈。 她就那樣靜靜地躺著,像睡著了一般睁蕾。 火紅的嫁衣襯著肌膚如雪苞笨。 梳的紋絲不亂的頭發(fā)上债朵,一...
    開封第一講書人閱讀 51,198評(píng)論 1 299
  • 那天,我揣著相機(jī)與錄音瀑凝,去河邊找鬼序芦。 笑死,一個(gè)胖子當(dāng)著我的面吹牛粤咪,可吹牛的內(nèi)容都是我干的谚中。 我是一名探鬼主播,決...
    沈念sama閱讀 40,084評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼寥枝,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼宪塔!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起囊拜,我...
    開封第一講書人閱讀 38,926評(píng)論 0 274
  • 序言:老撾萬榮一對(duì)情侶失蹤某筐,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后冠跷,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體南誊,經(jīng)...
    沈念sama閱讀 45,341評(píng)論 1 311
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,563評(píng)論 2 333
  • 正文 我和宋清朗相戀三年蔽莱,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了弟疆。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,731評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡盗冷,死狀恐怖怠苔,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情仪糖,我是刑警寧澤柑司,帶...
    沈念sama閱讀 35,430評(píng)論 5 343
  • 正文 年R本政府宣布,位于F島的核電站锅劝,受9級(jí)特大地震影響攒驰,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜故爵,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,036評(píng)論 3 326
  • 文/蒙蒙 一玻粪、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧诬垂,春花似錦劲室、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,676評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至隧枫,卻和暖如春喉磁,著一層夾襖步出監(jiān)牢的瞬間谓苟,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,829評(píng)論 1 269
  • 我被黑心中介騙來泰國(guó)打工协怒, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留涝焙,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 47,743評(píng)論 2 368
  • 正文 我出身青樓斤讥,卻偏偏與公主長(zhǎng)得像纱皆,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子芭商,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,629評(píng)論 2 354