第7章 MapReduce的工作機制

1、 作業的提交 可通過調用Job對象的submit()方法,也可以調用waitForCompletion()方法。 Job的submit()方法創建了一個內部的JobSummiter實例,並調用其submitJobInternal()方法。提交作業後,waitForCompletion()輪詢進度,有變化就打印到控制檯。作業完成後,若成功,顯示作業計數器,失敗則顯示失敗的錯誤記錄。 JobSum
相關文章
相關標籤/搜索