jstorm fieldsGrouping源碼分析

jstorm fieldsGrouping是如何找到下一個emit的task節點呢，如何保證相同的值路由要相同的task？ 在spout和bolt發射數據的時候都會調用 collector.emit(new Values(your data), msgId); 如果指定了fieldsGrouping，那麼jstorm會根據emit的數據(your data)計算下一個要發送的task， com.a

>>阅读原文<<