Storm事务Topology的接口介绍

Posted 2020-06-13

 

• 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的节点。