1、Spout
Spout最顶层抽象是ISpout接口。
Open()是初始化方法
nextTuple()循环发射数据
ack()成功处理tuple回调方法
fail()处理失败tuple回调方法
activate和deactivate:spout可以被暂时激活和关闭
close方法在该spout关闭前执行,但是并不能得到保证其一定被执行,kill -9 时不执行,Storm kill topoName时执行,如图:
上一篇[Windows Phone 8]如何启动浏览器并指定其网址WebBrowserTask
下一篇c#中的委托01
C#创建 WebApi 项目
窗体内的控件随窗体的大小改变控件大小
控制页面打印的2种方法(css3的media媒体查询和window.print())
【转】Windows Socket和Linux Socket编程有什么区别
Rails 的 API
C# 如何添加PDF页眉页脚
Windows下安装单机Kafka
Windows下php curl调用本地url 499问题