用實例理解Storm的Stream概念

事情源於在看基於Storm的CEP引擎：flowmix 的FlowmixBuilder代碼， 每個Bolt設置了這麼多的Group， 而且declareStream也聲明瞭這麼多的stream-id， 對於只寫過WordCountTopology的小白而言， 直接懵逼了，沒見過這麼用的啊，我承認一開始是拒絕的，每個Bolt都設置了這麼多Group，這TMD拓撲圖是什麼樣的？ 1 2 3 4 5 6

>>阅读原文<<