tail的特性Tail适合文本源不仅读取数据源,而且监听 一旦有变化,会把增量数据读取类似与tomcat的日志输出如果是Message Queue源的话,该特性没必要。Storm-starter官方提供的例子包最好的学习资料https://github.com/nathanmarz/storm-st...
分类:
系统相关 时间:
2015-08-03 12:58:42
阅读次数:
193
目录(一)搭建单机storm集群一、下载所需要的资源二、资源解压三、安装JDK四、安装依赖的库文件五、安装ZMQ六、安装jzmq七、启动zookeeper八、启动storm九、在UI端访问十、编译storm-start jar包十一、storm-starter源码导出十二、提交Topology(二)...
分类:
其他好文 时间:
2015-07-31 14:39:51
阅读次数:
385
Storm Starter例子RollingTopWords代码学习...
分类:
其他好文 时间:
2015-04-26 21:14:51
阅读次数:
825
storm的topology启动过程是执行strom jar topology1.jar MAINCLASS ARG1 ARG2鉴于前面已经分析了脚本的解析过程,现在重点分析topology1.jar的执行。以storm-starter中的ExclamationTopology为例,来进行剖析:pu...
分类:
其他好文 时间:
2015-04-16 19:46:05
阅读次数:
239
一个topology的启动包括了三个步骤 1)创建TopologyBuilder,设置输入源,输出源 2)获取config 3)提交topology(这里不考虑LocalCluster本地模式) 以storm.starter的ExclamationTopology为例:public static v...
分类:
其他好文 时间:
2015-01-22 12:46:55
阅读次数:
202
一个topology的启动包括了三个步骤1)创建TopologyBuilder,设置输入源,输出源2)获取config3)提交topology(这里不考虑LocalCluster本地模式)以storm.starter的ExclamationTopology为例:public static void ...
分类:
其他好文 时间:
2014-12-16 23:57:14
阅读次数:
332
Release Notes - Apache Storm - Version 0.9.2-incubating Sub-task [STORM-207] - Add storm-starter as a module [STORM-208] - Add storm-kafka as a module [STORM-223] - Safe YAML Parsing [STORM-232] - ...
分类:
Web程序 时间:
2014-12-12 15:07:15
阅读次数:
429
参考《CentOS6.4下Storm0.9.2单机版安装》的步骤在ubuntu上安装storm,中间遇到一些问题记录一下。参考文章链接:http://blog.csdn.net/qiyating0808/article/details/36041299我的linux环境:ubuntu-10.04.4-desktop-i386一,安装zeromq、jzmq及zookeeper时比较顺利,略过。ze..
分类:
其他好文 时间:
2014-09-25 13:37:19
阅读次数:
274
package storm.starter;import backtype.storm.Config;import backtype.storm.LocalCluster;import backtype.storm.LocalDRPC;import backtype.storm.StormSubmi...
分类:
其他好文 时间:
2014-09-23 21:33:45
阅读次数:
245
SingleJoinExample示例说明了storm中流聚合的应用,将具有相同tuple属性的数据流整合成一个新的数据流。来看一下Topology。先定义两个数据源genderSpout和ageSpout,Fields分别为("id", "gender")、("id"...
分类:
其他好文 时间:
2014-08-11 12:16:12
阅读次数:
253