[size=large]1、普通事務Spout[/size]
[size=large]2、事務Spout建立一個新的事務(中繼資料)metadata[/size]
[b]2、1中繼資料定義[/b]
[b]2、2 獲得(中繼資料)metadata,逐個發射實際batch的tuple[/b]
[size=large]------------------------spout與上篇相同-----------------------------------------[/size]
[size=x-large]3、按天統計資料事務Bolt,會從Emitter接收資料處理,處理完成,送出給finishBatch方法處理。[/size]
[size=large]4、接收統計資料,累加彙總MyDailyCommitterBolt,batch之間強制按照順序進行送出[/size]
[size=large]5、topo類[/size]
[size=large]6、測試結果[/size]
[quote]啟動一個事務:0----10
total==========================:10
啟動一個事務:10----10
total==========================:20
啟動一個事務:20----10
total==========================:30[/quote]