Storm事务Topology的接口介绍

  • 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的节点。
时间： 2024-12-16 07:10:59

Storm事务Topology的接口介绍的相关文章

storm事务

1. storm 事务 对于容错机制,Storm通过一个系统级别的组件acker,结合xor校验机制判断一个msg是否发送成功,进而spout可以重发该msg,保证一个msg在出错的情况下至少被重发一次.但是在一些事务性要求比较高的场景中,需要保障一次只有一次的语义,比如需要精确统计tuple的数量等等,torm0.7.0实现了一个新特性---事务性拓扑,这一特性使消息在语义上确保你可以安全的方式重发消息,并保证它们只会被处理一次.在不支持事务性拓扑的情况下,你无法在准确性,可扩展性,以空错性上

核心开发接口介绍

核心开发接口介绍1.hibernate_0500_CoreAPI2.HiberanteAPI 文档需要单独下载 在线api链接:http://docs.jboss.org/hibernate/core/3.3/api3.Configuration a) AnnotationConfiguration b) 进行配置信息的管理 c) 用来产生 SessionFactory d) 可以在 configure方法中指定hibernate配置文件 e) 只需关注一个方法即:buildSessionFac

Spring事务SPI及配置介绍

Spring事务SPI及配置介绍 标签: spring事务aop数据管理 2015-05-17 11:42 606人阅读 评论(0) 收藏 举报  分类: Spring(12)  版权声明:本文为博主原创文章,未经博主允许不得转载. Spring事务管理的抽象,核心的三个接口:PlatformTransactionManager.TransactionDefinition和TransactionStatus.关系如下图所示: TransactionDefinition:定义了Spring兼容的事

2 storm的topology提交执行

本博文的主要内容有 .storm单机模式,打包,放到storm集群 .Storm的并发机制图 .Storm的相关概念 .附PPT 打包,放到storm集群去.我这里,是单机模式下的storm. weekend110-storm  ->   Export   ->   JAR file   -> 当然,这边,肯定是,准备工作已经做好了.如启动了zookeeper,storm集群. 上传导出的jar sftp> cd /home/hadoop/ sftp> put c:/d de

SPI、I2C、UART三种串行总线协议的区别和SPI接口介绍（转）

SPI.I2C.UART三种串行总线协议的区别 第一个区别当然是名字: SPI(Serial Peripheral Interface:串行外设接口); I2C(INTER IC BUS) UART(Universal Asynchronous Receiver Transmitter:通用异步收发器) 第二,区别在电气信号线上: SPI总线由三条信号线组成:串行时钟(SCLK).串行数据输出(SDO).串行数据输入(SDI).SPI总线可以实现多个SPI设备互相连接.提供SPI串行时钟的SPI

Twitter Storm中Topology的状态

Twitter Storm中Topology的状态 状态转换如下,Topology 的持久化状态包括: active, inactive, killed, rebalancing 四个状态. 代码上看到每种状态都可以转换成一些持久化 ( 写入到 zk 中的状态 ) 或者中间状态. Java代码 (defn state-transitions [nimbus storm-id status] {:active {:monitor (reassign-transition nimbus storm-

Hive 接口介绍（Web UI/JDBC）

Hive 接口介绍(Web UI/JDBC) 实验简介 本次实验学习 Hive 的两种接口:Web UI 以及 JDBC. 一.实验环境说明 1. 环境登录 无需密码自动登录,系统用户名shiyanlou,密码shiyanlou 2. 环境介绍 本实验环境采用带桌面的Ubuntu Linux环境,实验中会用到桌面上的程序: XfceTerminal: Linux命令行终端,打开后会进入Bash环境,可以使用Linux命令: Firefox:浏览器,可以用在需要前端界面的课程里,只需要打开环境里写

Spring的BeanPostProcesser接口介绍

前言 废话不多说,直接进入主题. 同学们有想过这么一种情况吗:Spring容器提供给我们的一些接口实现类并不能满足我们的要求,但是我们又不想重新写一个类,只想在原来类上修改一些属性? 举个例子,SpringMVC中通过<mvc:annotation-driven>标签自动生成的RequestMappingHandlerAdapter有个HandlerMethodArgumentResolverComposite类型的argumentResolvers属性,这个属性内部有个HandlerMeth

微信公众平台开发(一)---接口介绍及配置

一.公众平台开发接口介绍 公众平台是为微信用户提供服务的平台,而公众平台开发接口则是提供服务的基础,开发者在公众平台网站中创建公众号.获取接口权限后,可以通过阅读本接口文档来帮助开发. 公众平台开发接口提供与用户进行消息交互.自定义菜单交互的能力.对于成功接入公众平台开发接口的公众账号,当用户发消息给公众号,微信公众平台服务器会使用http请求对接入的网址进行消息推送,第三方服务器可通过响应包回复特定结构,从而达到回复消息的目的. 二.注册微信平台公众帐号  (1)注册地址:https://mp