Storm事务Topology的接口介绍
2016-02-13 12:08
555 查看
ITransactionalSpout 基本事务Topology的Spout接口,内含两部分接口:协调Spout接口以及消息发送Blot接口。
TransactionalSpoutBatchExecutor Bolt类型,用于执行ITransactionalSpout中的消息发送Bolt节点。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120942792-1967563625.png)
TransactionalSpoutCoordinator Spout类型,用于执行ITransactionalSpout中的协调Spout节点,是系统中唯一的Spout节点,具体功能为初始化事务以及产生事务尝试消息等。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120946683-2021309082.png)
IPartitionedTransactionalSpout 分区的事务Topology的Spout接口,用户通过该接口完成Spout的分区功能。
PartitionedTransactionalSpoutExecutor 为ITransactionalSpout类型,主要用于适配IPartitionedTransactionalSpout接口,为IPartitionedTransactionalSpout的执行器。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120949308-95934431.png)
IOpaquePartitionedTransactionalSpout 分区的模糊事务Topology的Spout接口,用户通过该接口来完成模糊事务类型的Topology。
OpaquePartitionedTransactionalSpoutExecutor 为ICommitterTransactionalSpout类型,用于适配IOpaquePartitionedTransactionalSpout接口,为IOpaquePartitionedTransactionalSpout的执行器。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120955573-711593412.png)
ICommitterTransactionalSpout 具有提交功能的事务Topology的Spout接口,主要用于模糊事务Topology的Spout的节点。
TransactionalSpoutBatchExecutor Bolt类型,用于执行ITransactionalSpout中的消息发送Bolt节点。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120942792-1967563625.png)
TransactionalSpoutCoordinator Spout类型,用于执行ITransactionalSpout中的协调Spout节点,是系统中唯一的Spout节点,具体功能为初始化事务以及产生事务尝试消息等。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120946683-2021309082.png)
IPartitionedTransactionalSpout 分区的事务Topology的Spout接口,用户通过该接口完成Spout的分区功能。
PartitionedTransactionalSpoutExecutor 为ITransactionalSpout类型,主要用于适配IPartitionedTransactionalSpout接口,为IPartitionedTransactionalSpout的执行器。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120949308-95934431.png)
IOpaquePartitionedTransactionalSpout 分区的模糊事务Topology的Spout接口,用户通过该接口来完成模糊事务类型的Topology。
OpaquePartitionedTransactionalSpoutExecutor 为ICommitterTransactionalSpout类型,用于适配IOpaquePartitionedTransactionalSpout接口,为IOpaquePartitionedTransactionalSpout的执行器。
![](http://images2015.cnblogs.com/blog/141993/201602/141993-20160213120955573-711593412.png)
ICommitterTransactionalSpout 具有提交功能的事务Topology的Spout接口,主要用于模糊事务Topology的Spout的节点。
相关文章推荐
- opencv学习笔记(一):基于YCrCb颜色空间的肤色检测
- Csimsoft Trelis Pro 15.2.1 Win32_64 & MacOSX & Linux32_64 & Linux Debian32_64 7CD
- Docker实践1:Virtualbox安装Oracle Enterprise Linux R6 U5
- 用Docker运行Percona Server
- 一个简单的弹出对话框的shellcode(取自0day2一书)
- linux下ping的C语言实现
- pig: ERROR 1070
- pig实战演练:手机流量统计
- 关于weblogic server对docker的支持
- shell 10进制转16进制输出
- VMware创建Linux虚拟机
- VMware创建Linux虚拟机
- ansys 15 for linux 安装纪录
- Hadoop 排序 SortData
- Apache Shiro
- htop 2.0 发布!支持多平台
- linux /dev 常见设备文件介绍与应用
- 【Android】通过adb shell命令查看内存,CPU,启动时间,电量等信息
- Hadoop 求最大值 最小值 BiggestSmallest
- Hadoop 求平均值 Average