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