Kettle高階 Kitchen原始碼閱讀

2021-08-21 20:52:31 字數 1164 閱讀 6337

源**路徑:org.pentaho.di.kitchen.kitchen

kitchen是kettle用來啟動job的工具,使用者可以通過kitchen.sh指令碼執行job任務。現在我們來看kitchen是如何執行乙個job的。

開啟kitchen原始碼進入main()方法我們首先看到其初始化了乙個executorservice,該executor的主要作用是用來初始化kettle環境。

final executorservice executor = executorutil.getexecutor();

final repositoryplugintype repositoryplugintype = repositoryplugintype.getinstance();

//兩次submit初始化環境

final future>> repositoryregisterfuture =

executor.submit( new callable>>() catch ( kettlepluginexception e ) catch ( kettleexception e ) ;

每個引數的作用都有介紹,這就不多說了。

第四是構建repository。

//該例項會以.kettle資料夾下的repositories.xml的內容作為所有repository的元資訊

repositoriesmeta repsinfo = new repositoriesmeta();

repsinfo.getlog().setloglevel( log.getloglevel() );

try catch ( exception e ) else else {

system.out.println( "parameter: "

+ parametername + "=" + const.nvl( value, "" ) + " : " + const.nvl( descr, "" ) );

// stop right here...

exitjvm( 7 ); // same as the other list options

job.start();

job.waituntilfinished();

result = job.getresult(); // execute the selected job.

Kettle中pan和kitchen使用

kettle 命令列使用說明 1.kitchen 作業執行器 是乙個作業執行引擎,用來執行作業。這是乙個命令列執行工具,引數說明如下 1 rep repositoryname 任務包所在儲存名 2 user repositoryusername 執行人 3 pass repositorypasswo...

kettle 中kitchen和pan的使用

kettle中有四個主要的部件分別是作業 轉換 步驟 跳。其中作業和轉換能夠相互呼叫執行。每乙個轉換中的乙個執行單元叫做步驟,連線步驟之間的線叫做跳。在linux中我們通常使用kitchen和pan執行作業和轉換。kitchen用來執行作業,pan用來執行轉換。具體語法如下 kitchen.sh f...

kettle基礎入門 二 kettle定時任務執行

修改start的定時頻率後,需要關閉客戶端視窗,然後重新開啟spoon,重啟job 主要流程為 新建.bat檔案 建立win定時任務 定時執行.bat檔案 f kitchen.bat所在路徑碟符 cd f data integration kitchen.bat所在目錄 kitchen為執行job的...