首页 > 技术文章 > Storm事务Topology的接口介绍

yuananyun 2016-02-13 12:08 原文

 

  • ITransactionalSpout 基本事务Topology的Spout接口,内含两部分接口:协调Spout接口以及消息发送Blot接口。

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

TransalSpoutBatchExecutor

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

TransactionalSpoutCoordinator

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

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

PartitionedTransactionalSpoutExecutor

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

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

OpaquePartitionedTransactionalSpoutExecutor

  • ICommitterTransactionalSpout 具有提交功能的事务Topology的Spout接口,主要用于模糊事务Topology的Spout的节点。

推荐阅读