用实例理解Storm的Stream概念

事情源于在看基于Storm的CEP引擎：flowmix 的FlowmixBuilder代码， 每个Bolt设置了这么多的Group， 而且declareStream也声明了这么多的stream-id， 对于只写过WordCountTopology的小白而言， 直接懵逼了，没见过这么用的啊，我承认一开始是拒绝的，每个Bolt都设置了这么多Group，这TMD拓扑图是什么样的？ 1 2 3 4 5 6

>>阅读原文<<