Storm-源碼分析-Topology Submit-Executor-mk-threads

對於executor thread是整個storm最爲核心的代碼, 因爲在這個thread裏面真正完成了大部分工作, 而其他的如supervisor,worker都是封裝調用. 對於executor的mk-threads, 是通過mutilmethods對spout和bolt分別定義不同的邏輯 1. Spout Thread (defmethod mk-threads :spout [execut

>>阅读原文<<