Storm Worker中的線程

worker中的每個計時器都對應一個java線程,使用計數器進行心跳保持以及獲取元數據更新信息。 創建woker  mk-worker函數用於創建worker進程,主要工作包括:   啓動相應計時器   創建worker中對應的executor   啓動接收消息線程   worker心跳信息  do-heartbeat函數用戶產生worker的心跳信息,這些信息被寫入本地文件系統中。 superv
相關文章
相關標籤/搜索