Storm-源码分析-Topology Submit-Nimbus-mk-assignments
什么是executor, 参考Storm-源码分析- Component ,Executor ,Tas ...
原文：Storm-源码分析-Topology Submit-Nimbus
Nimbus Server Nimbus server, 首先从启动命令开始, 同样是使用storm命令 storm nimbus 来启动 看下源码, 此处和上面client不同, jvmtype server , 最终调用 backtype.storm.daemon.nimbus 的main nimbus是用clojure实现的, 但是clojure是基于JVM的, 所以在最终发布的时候会产生n ...
2013-06-19 15:28 5 2707 推荐指数：
相关推荐
Storm-源码分析-Topology Submit-Executor-mk-threads
对于executor thread是整个storm最为核心的代码, 因为在这个thread里面真正完成了大部分工作, 而其他的如supervisor,worker都是封装调用. 对于executor的mk-threads, 是通过mutilmethods对spout和bolt分别定义 ...
Storm-源码分析-Topology Submit-Client
1 Storm Client 最开始使用storm命令来启动topology, 如下 storm jar storm-starter-0.0.1-SNAPSHOT-standalone.jar storm.starter.WordCountTopology 这个storm命令 ...
Storm-源码分析-Topology Submit-Task-TopologyContext (backtype.storm.task)
1. GeneralTopologyContext 记录了Topology的基本信息, 包含StormTopology, StormConf 已经从他们推导出的, task和component, component的streams, input/output信息 ...
Storm-源码分析- metric
, (backtype.storm.daemon.builtin-metrics), 并注册到topology context里面 task会不断的利用如spout-ack ...
storm启动nimbus源码分析-nimbus.clj
nimbus是storm集群的"控制器"，是storm集群的重要组成部分。我们可以通用执行bin/storm nimbus >/dev/null 2>&1 &来启动nimbus。bin/storm是一个python脚本，在这个脚本中定义了一个nimbus函数 ...
Storm-源码分析- Thrift的使用
1 IDL 首先是storm.thrift, 作为IDL里面定义了用到的数据结构和service 然后backtype.storm.generated, 存放从IDL通过Thrift自动转化成的Java代码 比如对于nimbus service 在IDL的定义为, 而对 ...
storm源码分析之topology提交过程
storm集群上运行的是一个个topology，一个topology是spouts和bolts组成的图。当我们开发完topology程序后将其打成jar包，然后在shell中执行storm jar xxxxxx.jar xxxxxxxClass就可以将jar包上传到storm集群的nimbus ...