并发度一个Topology可以包含一个或多个worker(并行的跑在不同的machine上), 所以worker process就是执行一个topology的子集, 并且worker只能对应于一个top ology一个worker可用包含一个或多个executor, 每个component (spo...
分类：
其他好文 时间：
2015-12-25 13:33:31
阅读次数：
151
https://storm.apache.org/documentation/Setting-up-a-Storm-cluster.html -官方文档http://xumingming.sinaapp.com/185/twitter-storm-在生产集群上运行topology/ --徐明明htt...
分类：
其他好文 时间：
2015-12-21 12:27:11
阅读次数：
129
StormAPI StormAPI○ StormAPI基本概念Storm称用户的一个作业为 作业=Topology=拓扑 拓扑是由一些点和边组成的有向无关图，点有两种，一种是数据源节点(Spout)，另一种是普通...
启动gui： 进入ryu目录 $PYTHONPATH=. ./bin/ryu run --observe-links ryu/app/gui_topology/gui_topology.py 打开127.0.0.1:8080 mininet@mininet-vm:~$ sudo mn --c...
分类：
其他好文 时间：
2015-12-04 14:50:28
阅读次数：
161
问题导读1.如何设置storm内存？2.如果没有配置文件的情况下，该如何配置一些参数?3.通过哪个参数可以配置内存？Storm中真正干活的是各个worker，而worker由supervisor负责启动。在topology启动过程中我们会看到如下的启动日志： 这就是启动一个w...
分类：
系统相关 时间：
2015-12-03 22:48:43
阅读次数：
257
4.1 简介 storm可以确保spout发送出来的每个消息都会被完整的处理。本章将会描述storm体系是如何达到这个目标的，并将会详述开发者应该如何使用storm的这些机制来实现数据的可靠处理。4.2 理解消息被完整处理TopologyBuilder builder = new Topology....
分类：
Web程序 时间：
2015-11-28 19:56:21
阅读次数：
248
前段时间学习了storm，最近刚开blog，就把这些资料放上来供大家参考。 这个框架用的组件基本都是最新稳定版本，flume-ng1.4+kafka0.8+storm0.9+mysql （项目是maven项目，需要改动mysql配置，提供两种topology：读取本地文件（用来本地测试）；读取服务器...
分类：
数据库 时间：
2015-11-26 21:12:39
阅读次数：
665
JTS是Java的处理地理数据的API，它提供以下功能：实现了OGC关于简单要素SQL查询规范定义的空间数据模型一个完整的、一致的、基本的二维空间算法的实现，包括二元运算（例如touch和overlap）和空间分析方法（例如intersection和buffer）一个显示的精确模型，用算法优雅的解决...
分类：
编程语言 时间：
2015-11-24 22:50:14
阅读次数：
354
3种Scheduler概述EventScheduler：将系统中的可用资源均匀地分配给需要资源的topology，其实也不是绝对均匀，后续会详细说明DefaultScheduler：和EvenetScheduler差不多，只不过会先将其它topology不需要的资源重新收集起来，再进行EventSc...
分类：
编程语言 时间：
2015-11-08 23:45:00
阅读次数：
310
弄 org.apache.storm storm-core 0.9.5经常使用类backtype.storm.topology.TopologyBuilder用来建立topology。SpoutDeclarer backtype.storm.topology.TopologyBuilder.setS...
分类：
其他好文 时间：
2015-10-27 23:22:08
阅读次数：
224
