天天看點

Giraph中有關Aggretor的處理過程

         在Giraph中,Aggretor的作用與Hama中類似,可以全局共享或者操作某一個變量,經過對源碼的研究和整理,現給出在Giraph中有關Aggretor的處理過程,主要是包含Worker與Master之間的互動過程。詳細區分可以分成:worker手收集本地局部aggretor值、worker将局部aggregator值分發到它所屬的worker、worker擷取屬于本worker的局部aggretor并進行合并、worker将最終結果發送給master、master收集來自worker的aggretor并彙總、master在每個超級不開始将aggretor分發到重新配置設定的worker上、每個woker接收來自master的屬于自己的aggretor、worker将收到的aggertor告知其他所有worker以便在下個超級步中通路、每個worker接受并存儲全局aggretor以便使用等過程,具體見下圖:

Giraph中有關Aggretor的處理過程

繼續閱讀