2019独角兽企业重金招聘Python工程师标准>>>

Component

在Storm 之中，Spout 和Bolt 都是其Compnent，所以在Storm之中定义了一个名叫 IComponent

的总接口

Spout

在前面的基本例子中，我们实现了一个RandomSout，来看看其类图

Spout的最顶级的抽象是ISpout接口

有关如下的API

1：oepn 方法是初始化动作：允许你在该spout 初始化时做一些动作，传入了上写文，也方便娶上下文的一些数据

2 ：close 方法在该Spout 关闭前执行，但是并不能得到保证其一定会执行，spout是作为task 运行，在worker内的，在

clouster 集群之下，我们的 supervisor 会直接kill掉，这样它就有可能不会允许，而在本地的模式之下，只要不是kill -9，如果是发送停止命令，是可以保证close的执行的。

3 : Activate

4 :deactivate

5: nextTuple : nextTuple 用来发送数据

6 ack ( Object ) : Ack 传入的Object其实是一个id. 表示唯一一个tuple

7 fail ( Object )

由于继承了BaseRichSpout，所以不用实现 close，activate，deactivate，ack，fail

等方法。

结论：

在通常的情况之下，(Shel 和事物型的除外)，实现一个Spout，可以直接的去实现IRichSpout

如果不想写IRIchSpout代码，可以继承自BaseRichSpout

Bolt

ExclaimBasicBolt的类图

Ibolt 继承了java.io.Serializable 我们在nimbus上提交了topology

execute 接受一个tuple进行处理，并在prepare 方法传入的 ACK方法，或者fail方法表示来反馈处理的结果

通常情况之下，他实际上相当于自动做掉prepare方法和collector.emit.ack(inputTupe);

转载于:https://my.oschina.net/infiniteSpace/blog/284060

Spout 【API 解析】 -spout-bolt-相关推荐

JavaScript 对象所有API解析【2020版】
写于 2017年08月20日,虽然是2017年写的文章,但现在即将2020年依旧不过时,现在补充了2019年新增的ES10 Object.fromEntries().发到公众号申明原创.若川顺便在此提 ...
java微信开发API解析（二）-获取消息和回复消息
java微信开发API解析(二)-获取消息和回复消息说明 * 本演示样例依据微信开发文档:http://mp.weixin.qq.com/wiki/home/index.html最新版(4/3/20 ...
Java 调用Google Map Api解析地址，解析经纬度实例
Java 调用Google Map Api解析地址,解析经纬度实例使用google地图的反向地址解析功能,提供一个经纬度得到对应地址,或者给出模糊地址,得到经纬度,放在java后台代码中处理,这个使 ...
使用 MediaExtractor 和 MediaMuxer API 解析和封装 mp4 文件
一个音视频文件是由音频和视频组成的,我们可以通过MediaExtractor.MediaMuxer把音频或视频给单独抽取出来,抽取出来的音频和视频能单独播放: 一.MediaExtractor API ...
SDL开发（一）：SDL简介及2.0核心API解析
文章目录零. 参考文献一. 什么是SDL? 1. SDL 库分类 2. SDL 子系统分类二. SDL2.0核心API解析 1. 初始化函数 SDL_Init() 2. 创建窗口 SDL_Cre ...
【API解析】微软文本转语音(text-to-speech)官方Demo调用步骤
[API解析]微软文本转语音(text-to-speech)官方Demo调用步骤 1. 来源 github: MsEdgeTTS 吾爱破解:微软语音助手免费版,支持多种功能,全网首发微软Demo: ...
React16常用api解析以及原理剖析
React16常用api解析以及原理剖析目录 Vue 与 React 两个框架的粗略区别对比 react 16 版本常见 api react 生命周期 react 事件机制 react.Compon ...
mediawiki java api_维基百科 MediaWiki API 解析
使用开放的 API 做一个自己的小项目,是一个很好的学习方法.但好像开放的 API 选择并不多.这里给大家多一个选择,简单介绍一下维基百科使用的 MediaWiki API. 简介先简单介绍几个容易 ...
REST API解析
REST API 第一次接触REST API时有些迷惑,后来查阅了一些相关的文章并结合上自己的一些总结,总算对其有粗略的了解. 1. 起源 REST这个词,是Roy Thomas Fielding ...
在Java 8中使用Stream API解析文件
Java 8中到处都有流.只需四处看看,可以肯定地找到它们. 它也适用于java.io.BufferedReader . 使用Stream API在Java 8中解析文件非常容易. 我有一个要读取的C ...

Spout 【API 解析】 -spout-bolt-

Component

Spout 【API 解析】 -spout-bolt-相关推荐

最新文章

热门文章