天天看點

普通事務ITransactionalSpout執行個體之按天統計資料

[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]

上一篇: strom相關