天天看点

普通事务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相关