本月博客排行
-
第1名
龙儿筝 -
第2名
lerf -
第3名
zysnba - xiangjie88
- sgqt
年度博客排行
-
第1名
青否云后端云 -
第2名
宏天软件 -
第3名
gashero - wallimn
- wy_19921005
- vipbooks
- benladeng5225
- 龙儿筝
- javashop
- fantaxy025025
- ranbuijj
- zw7534313
- qepwqnp
- e_e
- 解宜然
- zysnba
- ssydxa219
- sam123456gz
- sichunli_030
- arpenker
- tanling8334
- kaizi1992
- xpenxpen
- gaojingsong
- jh108020
- wiseboyloves
- xiangjie88
- ganxueyun
- xyuma
- wangchen.ily
- jbosscn
- lemonhandsome
- zxq_2017
- mengjichen
- luxurioust
- lzyfn123
- forestqqqq
- nychen2000
- Xeden
- zhanjia
- wjianwei666
- ajinn
- hanbaohong
- 喧嚣求静
- jickcai
- kingwell.leng
- mwhgJava
- daizj
- silverend
- lich0079
最新文章列表
Example Storm Topologies
Learn to use Storm!
Table of Contents
Getting started
Using storm-starter with Leiningen
Using storm-starter with Maven
storm started
Tutorial
In this tutorial, you'll learn how to create Storm topologies and deploy them to a Storm cluster. Java will be the main language used, but a few examples will use Python to illu ...
Creating a new Storm project
Creating a new Storm project
This page outlines how to set up a Storm project for development. The steps are:
Add Storm jars to classpath
If using multilang, add multilang dir to clas ...
Setting up development environment
Setting up development environment
This page outlines what you need to do to get a Storm development environment set up. In summary, the steps are:
Download a Storm release , unpack it ...
Running topologies on a production cluster
Running topologies on a production cluster is similar to running in Local mode. Here are the steps:
1) Define the topology (Use TopologyBuilder if defining using Java)
2) Use StormSubmitter to subm ...
Distributed RPC
Distributed RPC
The idea behind distributed RPC (DRPC) is to parallelize the computation of really intense functions on the fly using Storm. The Storm topology takes in as input a stream ...
Storm Local mode
Local mode
Local mode simulates a Storm cluster in process and is useful for developing and testing topologies. Running topologies in local mode is similar to running topologies on a clu ...
Twitter Storm源代码分析之TimeCacheMap
TimeCacheMap是Twitter Storm里面一个类, Storm使用它来保存那些最近活跃的对象,并且可以自动删除那些已经过期的对象。这个类设计的很巧妙, 我们来看一下。
TimeCacheMap里面的数据是保存在内部变量_bucket里面的:
Common patterns
This page lists a variety of common patterns in Storm topologies.
Streaming joins
Batching
BasicBolt
In-memory caching + fields grouping combo
Streaming top N
TimeCacheMap for efficiently keep ...
eclipse中storm实战入门
功能描述:实时随机输出一字符串。
在开发前记得导入storm需要的jar包。1、SimpleSpout类继承BaseRichSpout类,用来产生数据并且向topology里面发出消息:tuple。
package com.ljq.helloword;
import java.util.Map;
import java.util.Random;
import bac ...
Maven构建storm
Maven
To develop topologies, you'll need the Storm jars on your classpath. You should either include the unpacked jars in the classpath for your project or use Maven to include Storm as ...
用jvisualvm监控远程java程序
jvisualvm是一个JDK自带的java性能监控程序。对于本地监控,直接启动jvisualvm, 在它面板里面就可以看到所有在运行的java程序。但是如果要监控在别的机器上运行的java程序,那么运行的时候要多加几个参数(假设我们的类名字叫Hello):
storm & drcp
1.Storm 在taobao的使用情况:
We make statistics of logs and extract useful information from thestatistics in almost real-time with Storm. Logs are read from Kafka-likepersistent message queue ...
Easy, Real-Time Big Data Analysis Using Storm
Conceptually straightforward and easy to work with, Storm makes handling big data analysis a breeze.
Today, companies regularly generate terabytes of data in their daily operations. The sources ...
storm & metaq 实例
目录
Storm项目:流数据监控 <4>. 1
---流数据监控MetaQ接口... 1
1 文档说明... 1
2 MetaQ与Storm接口... 1
2.1 MetaqSpout. 1
2.1.1 接口说明... 1
2.1.2 上代码... 2
2.2 MetaqBolt. 5
Storm实时处理方案架构
1 文档说明
该文档描述的是以storm为主体的实时处理架构,该架构包括了数据收集部分,实时处理部分,及数据落地部分。
关于不同部分的技术选型与业务需求及个人对相关技术的熟悉度有关,会一一进行分析。
该架构是本人所掌握的一种架构,可能会与其他架构有相似的部分,个人会一一解释对其的理解。
2 实时处理架构
Storm的介绍与安装(简单)
Storm的集群跟hadoop的集群非常像。但是在Hadoop上面你运行的是MapReduce的Job, 而在Storm上面你运行的是Topology。
在Storm的集群里面有两种节点: 控制节点(master node)和工作节点(worker node)。控制节点上面运行一个后台程序: Nimbus, 它的作用类似Hadoop里面的JobTracker。Nimbus负责在集群里面分布代码 ...