首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

聊聊storm trident的state

TRANSACTIONAL, OPAQUE } StateType有三种类型,NON_TRANSACTIONAL非事务性,TRANSACTIONAL事务性,OPAQUE不透明事务 对应的spout也有三类,non-transactional...src/jvm/org/apache/storm/trident/state/State.java /** * There's 3 different kinds of state: * * 1. non-transactional...be null for things like partitionPersist occuring off a DRPC stream void commit(Long txid); } non-transactional...值来进行update的,算出newVal 小结 trident严格按batch的顺序更新state,比如txid为3的batch必须在txid为2的batch处理完之后才能处理 state分三种类型,分别是non-transactional...、transactional、opaque transactional,对应的spout也是这三种类型 non-transactional无法保证exactly once,它可能是at-least once

29210

聊聊storm trident的state

TRANSACTIONAL, OPAQUE } StateType有三种类型,NON_TRANSACTIONAL非事务性,TRANSACTIONAL事务性,OPAQUE不透明事务 对应的spout也有三类,non-transactional...src/jvm/org/apache/storm/trident/state/State.java /** * There's 3 different kinds of state: * * 1. non-transactional...be null for things like partitionPersist occuring off a DRPC stream void commit(Long txid); } non-transactional...值来进行update的,算出newVal 小结 trident严格按batch的顺序更新state,比如txid为3的batch必须在txid为2的batch处理完之后才能处理 state分三种类型,分别是non-transactional...、transactional、opaque transactional,对应的spout也是这三种类型 non-transactional无法保证exactly once,它可能是at-least once

57640
领券