jstorm fieldsGrouping源码分析

jstorm fieldsGrouping是如何找到下一个emit的task节点呢，如何保证相同的值路由要相同的task？ 在spout和bolt发射数据的时候都会调用 collector.emit(new Values(your data), msgId); 如果指定了fieldsGrouping，那么jstorm会根据emit的数据(your data)计算下一个要发送的task， com.a

>>阅读原文<<