您的位置:首页 > 运维架构

Storm事务Topology的接口介绍

2016-02-13 12:08 555 查看
ITransactionalSpout 基本事务Topology的Spout接口,内含两部分接口:协调Spout接口以及消息发送Blot接口。

TransactionalSpoutBatchExecutor Bolt类型,用于执行ITransactionalSpout中的消息发送Bolt节点。



TransactionalSpoutCoordinator Spout类型,用于执行ITransactionalSpout中的协调Spout节点,是系统中唯一的Spout节点,具体功能为初始化事务以及产生事务尝试消息等。


IPartitionedTransactionalSpout 分区的事务Topology的Spout接口,用户通过该接口完成Spout的分区功能。

PartitionedTransactionalSpoutExecutor 为ITransactionalSpout类型,主要用于适配IPartitionedTransactionalSpout接口,为IPartitionedTransactionalSpout的执行器。



IOpaquePartitionedTransactionalSpout 分区的模糊事务Topology的Spout接口,用户通过该接口来完成模糊事务类型的Topology。

OpaquePartitionedTransactionalSpoutExecutor 为ICommitterTransactionalSpout类型,用于适配IOpaquePartitionedTransactionalSpout接口,为IOpaquePartitionedTransactionalSpout的执行器。



ICommitterTransactionalSpout 具有提交功能的事务Topology的Spout接口,主要用于模糊事务Topology的Spout的节点。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: