每次配置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 ...