StormAPI StormAPI○ StormAPI基本概念Storm称用户的一个作业为 作业=Topology=拓扑 拓扑是由一些点和边组成的有向无关图，点有两种，一种是数据源节点(Spout)，另一种是普通...
结构：RandomWordSpout：package cn.itcast.stormdemo;import java.util.Map;import java.util.Random;import backtype.storm.spout.SpoutOutputCollector;import ba...
分类：
其他好文 时间：
2015-12-11 20:31:55
阅读次数：
224
4.1 简介 storm可以确保spout发送出来的每个消息都会被完整的处理。本章将会描述storm体系是如何达到这个目标的，并将会详述开发者应该如何使用storm的这些机制来实现数据的可靠处理。4.2 理解消息被完整处理TopologyBuilder builder = new Topology....
分类：
Web程序 时间：
2015-11-28 19:56:21
阅读次数：
248
Todo:对Flume的sink进行重构，调用kafka的消费生产者(producer)发送消息;在Sotrm的spout中继承IRichSpout接口，调用kafka的消息消费者(Consumer)来接收消息，然后经过几个自定义的Bolt，将自定义的内容进行输出编写KafkaSink从$KAFKA...
分类：
Web程序 时间：
2015-11-27 17:43:28
阅读次数：
290
理清一下worker、executor、task、supervisor、nimbus、zk这几个之间的关系先来看一张图（图片来自：http://www.cnblogs.com/foreach-break/p/storm_worker_executor_spout_bolt_simbus_superv...
分类：
其他好文 时间：
2015-10-31 20:02:11
阅读次数：
308
jstorm开发指南-写个简单的jstorm应用发表于 2015-07-18 | 分类于大数据 | 暂无评论jstorm 是阿里巴巴开源的基于storm采用Java重写的一套分布式实时流计算框架，使用简单，特点如下：开发非常迅速: 接口简单，容易上手，只要遵守Topology，Spout， Bol....
分类：
Web程序 时间：
2015-10-15 20:28:13
阅读次数：
369
-----------------------------WordSpout? ? package?com.hzw.storm.Spout; ? import?java.util.Map; import?java.util.Random; ? import?backtype.storm.spout.SpoutOutputCollector; import?backt...
分类：
其他好文 时间：
2015-10-12 21:12:59
阅读次数：
267
storm是grovvy写的kafka是scala写的storm-kafkastorm连接kafkaconsumer的插件下载地址：https://github.com/wurstmeister/storm-kafka-0.8-plus除了需要storm和kafka相关jar包还需要google-collections-1.0.jar以及zookeeper相关包curator-framework-1.3.3.jar和curator-client..
分类：
其他好文 时间：
2015-10-09 18:29:00
阅读次数：
278
1.Storm命令 在Linux中观直接输入Storm，不带任何参数信息，可以查看Storm命令。 参考这里 1.activate 激活指定的拓扑Spout。语法：storm activate topology-name 2.classpath 打印出Storm客户端运行命令时使用的...
分类：
其他好文 时间：
2015-09-15 16:28:46
阅读次数：
174
