storm的act机制原理

act机制总结 1、spout发送的一条消息,会有系统生成一个ROOTID(一个64为随机数) 2、由于用户在发送数据的时候,指定了meeeageId,所以在发送数据的时候,会创建一个pendingMap       map以ROOTID为key,以用户的messageId为value DataTuple:含有数据 ActTuple:不含有数据   含有ROOTID 锚点ID 3、spout将数据
相关文章
相关标签/搜索