在Storm中IBasicBolt的主要作用是为用户提供一种更为简单的Bolt编写方式，更为简单体现在Storm框架本身帮你处理了所发出消息的Ack、Fail和Anchor操作，而这部分操作是由执行器BasicBoltExecutor 实现的。 下面我们看一下BasicBoltExecutor的源码 ...
分类：
Web程序 时间：
2017-08-02 10:21:55
阅读次数：
222
storm1.1.0 drpc 部署和调用测试 org.apache.storm.security.auth.AuthUtils.GetTransportPlugin(AuthUtils.java:267) at org.apache.storm.security.auth.ThriftCli... ...
分类：
其他好文 时间：
2017-07-31 20:07:41
阅读次数：
842
1、下载原安装文件和破解文件：magnet:?xt=urn:btih:7FD357910B7AFBFC8FBA3647A2FAC8F15F0D02F0 （直接放到迅雷里下载） 2、Licence Service是破解文件，根据你的计算机来安装相应文件（32、64位） 找到破解的安装地址并用cmd打开 ...
分类：
Web程序 时间：
2017-07-31 20:04:36
阅读次数：
239
消息通过各种方式进入到Kafka消息中间件，比如可以通过使用Flume来收集日志数据，然后在Kafka中路由暂存，然后再由实时计算程序Storm做实时分析，最后将结果保存在HDFS中，这时我们就需要将在Storm的Spout中读取Kafka中的消息，然后交由具体的Spot组件去分析处理。下面开发一个 ...
分类：
其他好文 时间：
2017-07-31 19:52:51
阅读次数：
1616
本文主要是解析SpoutOutputCollector源码，顺便分析该类中所涉及的设计模式–代理模式。 首先介绍一下Spout输出收集器接口–ISpoutOutputCollector,该接口主要声明了以下3个抽象方法用来约束ISpoutOutputCollector的实现类。接口定义与方法说明如下 ...
分类：
Web程序 时间：
2017-07-31 10:03:02
阅读次数：
249
转载请在页首明显处注明作者与出处 http://www.cnblogs.com/zhuxiaojie/p/7224772.html 一：说明 此为大数据系列的一些博文，有空的话会陆续更新，包含大数据的一些内容，如hadoop,spark,storm,机器学习等。 当前使用的hadoop版本为2.6. ...
分类：
其他好文 时间：
2017-07-30 13:44:42
阅读次数：
199
win7系统新安装的phpstorm2017.2版本，试了很多输入法，要么是不显示候选次，要么是输入法候选词总是在屏幕右下角，没有跟随光标移动。百度很久，重要找到解决方案。 就是替换phpstorm安装目录下的 jre64文件夹。 下载 https://bintray.com/jetbrains/i ...
分类：
Web程序 时间：
2017-07-30 00:59:45
阅读次数：
304
本节内容： Apache Storm是什么 Apache Storm核心概念 Storm原理架构 Storm集群安装部署 启动storm ui、Nimbus和Supervisor 一、Apache Storm是什么 Apache Storm是自由开源的分布式实时计算系统，擅长处理海量数据，适用于数据 ...
分类：
其他好文 时间：
2017-07-29 22:21:49
阅读次数：
179
今天在做storm on maven的时候发现要依赖到storm-hdfs的jar。自己又非常不想把乱七八糟的东西丢上自己的集群lib。于是就想maven 打包的时候把插件一块打包进jar。maven默认自己不会打包进jar，我只要把自己需要的打包进去就好了。 走了不少弯路，现在记录一把，防止以后自 ...
分类：
编程语言 时间：
2017-07-29 12:48:00
阅读次数：
197
EvenScheduler同DefaultScheduler一样,同样实现了IScheduler接口, 由下面代码可以看出: 它是通过调用schedule-topologies-evenly方法来完成任务分配的. schedule-topologies-evenly方法的具体定义如下: fn1: f ...
分类：
Web程序 时间：
2017-07-29 10:10:25
阅读次数：
450
