source code:package stormdemo;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.FileNotFoundException;import java.io.FileRead...
分类:
其他好文 时间:
2015-02-13 09:16:07
阅读次数:
132
Concepts:概念 原文:http://storm.apache.org/documentation/Concepts.html 这个列表展示了storm中的主要概念和相关详细信息。这些概念是: Topologies Streams Spouts Bolts Stream groupings Reliability Tas...
分类:
其他好文 时间:
2015-02-10 20:26:09
阅读次数:
326
中国大数据技术大会首日全体大会上,腾讯数据平台部助理总经理蒋杰发表了题为《大数据处理的规模化与实时化演进 》的演讲。他分享了大数据技术在腾讯的实践,其中包括基于Hadoop的平台TDW、实时数据收集系统TDBank以及基于Storm的流处理系统TRC。同时,蒋杰还透露,腾讯将在12月开源内部的Had...
分类:
其他好文 时间:
2015-02-09 12:47:57
阅读次数:
177
Splunk vs. Sumo Logic vs. LogStash vs. GrayLog vs. Loggly vs. PaperTrails vs. Splunk>Storm英文原文:The 7 Log Management Tools You Need To Know日志管理工具有 Splu...
分类:
编程语言 时间:
2015-02-08 23:02:37
阅读次数:
386
1、在使用Java API访问之前先在安装有kafka的各个节点启动服务
bin/kafka-server-start.sh config/server.properties &
2、报如下错误
props.put("metadata.broker.list", "storm1:9092,storm2:9092,storm3:9092");
props.put("serializer.cl...
分类:
其他好文 时间:
2015-02-07 18:56:33
阅读次数:
174
本题其实就是storm的wordcout,需要把一个gz压缩的文件读取,并使用storm计算其pv. 样本 数据: 存储为accesslog.gz 我把它加载到我的虚拟机中/mnt/下。 没有使用trident,刚学习最基本的。 所以把spout的数目设定为1. 把文件路径存储在config 的ma...
分类:
其他好文 时间:
2015-02-07 14:25:20
阅读次数:
258
本次实验的环境为VM station 10 安装三个虚拟机,系统为centOS6.5。IP分别如下图。如下图,三个虚拟机均安装了Java1.7以及配置好了hosts文件。接着是下载zookeeper-3.4.6(这里推荐使用此版本),进入conf目录下,将zoo_sample.cfg复制成zoo.c...
分类:
其他好文 时间:
2015-02-02 21:17:24
阅读次数:
191
本文根据自己的了解,对学习storm所需的一些知识进行汇总,以备之后详细了解。 maven工具Vagrantstormeclipseredisnodejs
分类:
其他好文 时间:
2015-02-01 17:39:44
阅读次数:
148
从Storm看集群管理
简介
Storm是当前最流行的分布式实时计算平台,使用场景是根据Storm定义的接口规范编写一个实时处理流,然后提交到Storm平台处理,Storm平台解析该处理流,使其并行、分布式地在集群中运行,并附带相应的状态监控。本文主要描述Storm的集群管理这块的内容,处理流的相关接口逻辑规范不作涉及。
Storm集群监控管理的目标是管理和监控用户提交的...
分类:
其他好文 时间:
2015-01-31 18:02:37
阅读次数:
666
Storm-Kafka模块之写入kafka-KafkaBolt的使用及实现...
分类:
其他好文 时间:
2015-01-26 12:02:24
阅读次数:
908