storm trident 事务和 spout和state有关

标签：额外   actor   val   一个   AC   long   控制   batch   gets   

首先spout有三种：这些关系到相同的batchid里面是否包含相同的tuple
事务性：相同
模糊事务性：如果取不到原来的，则拿新的
无事务：不一定

所以只有事务性才能做到一个tuple唯一一次处理
模糊事务性 才能做到 最多处理一次
而无事务，则可能处理多次

————————

而在State这里，
它会提供两个方法基类方法：
beginCommit(Long txid)
commit(Long txid)
来完成事务性操作
如果真正要完成事务型操作，需要写txid或者preval到数据库里，才能真正实现数据的事务
这需要实现上面两个方法，storm已经提供了实现了这两个方法的State，这样写到数据库里，会有额外信息，比如MemcacheState

但是很多State在这两个方法的实现里都是空，所以也就是并没有做相关的数据，只是简单的数据持久化
但是要做到一条数据最多只被处理一次，那么只需要控制spout就可以了，State不需要做什么

对State可以有query，update方法，来将数据通过State方法，持久化！！

persist的时候，需要调用getStateFactory操作回去StateFactory，然后要有一个updater方法，里面调用State的update方法，来实现数据的持久化
查询的过程，是StateFactory+query方法，这个query方法调用State的query方法

State里的update和query，最好是批量的，这样可以减少和数据库的交互次数！！

可以研究一下Hbase的State！

storm trident 事务和 spout和state有关

标签：额外   actor   val   一个   AC   long   控制   batch   gets   

原文地址：https://www.cnblogs.com/brainstorm/p/9094890.html