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

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

Storm事务Topology的接口介绍

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

Storm事务Topology的接口介绍

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

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

Storm事务Topology的接口介绍

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

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

Storm事务Topology的接口介绍

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

相关文章:

  • 2021-07-23
  • 2021-05-26
  • 2021-11-28
  • 2021-11-27
  • 2021-06-21
猜你喜欢
  • 2021-10-05
  • 2022-01-10
  • 2022-02-04
  • 2022-01-09
  • 2021-06-17
相关资源
相似解决方案