讀hadoop0 23原始碼 1 Job

2021-09-12 03:32:21 字數 586 閱讀 2362

每次配置job的時候,最後一步總是

system.exit(job.waitforcompletion(true) ? 0 : 1);
進入waitforcompletion方法

public boolean waitforcompletion(boolean verbose

) throws ioexception, interruptedexception,

classnotfoundexception

if (verbose) else

return issuccessful();

}

submit()方法是根據你設定的job屬性來執行job,以下是submit()方法:

public void submit() throws ioexception, interruptedexception, 

classnotfoundexception

在connect()方法中例項化了jobclient,然後呼叫jobclient.submitjobinternal 提交job

hadoop原始碼閱讀 1 原始碼目錄結構

由於版本的不同,可能部分目錄有些不同.bin 此目錄下為進行hadoop配置 執行以及管理的shell命令集合 c 此目錄下為linux下amd64 64位系統以及i386 32位系統提供的庫檔案集合 conf 此目錄下為執行與配置hadoop環境需要的配置檔案以及示例檔案集合,實際執行時可以對照此...

hadoop原始碼閱讀 1 原始碼目錄結構

由於版本的不同,可能部分目錄有些不同.bin 此目錄下為進行hadoop配置 執行以及管理的shell命令集合 c 此目錄下為linux下amd64 64位系統以及i386 32位系統提供的庫檔案集合 conf 此目錄下為執行與配置hadoop環境需要的配置檔案以及示例檔案集合,實際執行時可以對照此...

讀Muduo原始碼筆記 1

物件銷毀時出現的競態條件 執行緒安全的類 簡單的執行緒安全類 class counter int value const int getandincrease private int value mutable mutexlock mutex int counter value const int ...