mapreduce 的工作機制

本節將會從作業的角度來解釋一個作業是如何在Hadoop的MapReduce計算框架下提交、運行等。 一個MapReduce作業運行過程如圖 作業提交 用戶的MapReduce作業運行時己經設置作業運行時的各種信息,如Mapper類、Reducer類等,並通過job.waitForCompletion方法提交作業,如下圖所示。     首先由JobClient的subJobInternal方法提交作
相關文章
相關標籤/搜索