storm源码走读

启动场景分析

nimbus启动场景分析

2.1 程序入口
2.2 配置文件读取
2.2.1 配置文件的内容
2.3 thrift
2.4 zookeeper
supervisor启动场景分析
3.1 程序入口
3.2 zookeeper
3.2.1 event-manager
3.3 sync-processes
Topology
Topology提交过程
4.1 StormBuilder
4.1.1 setSpout
4.1.2 setBolt
4.1.3 createTopology
4.2 storm client
4.3 nimbus
4.3.1 submitTopologyWithOpts
4.3.2 normalize-topology
4.3.3 mk-assignments
4.3.4 Topology Monitoring
4.4 supervisor
4.5 worker
4.6 executor
4.6.1 spout
4.6.2 bolt
worker进程中线程的种类及用途
5.1 接收和发送线程
5.2 zk client. .
5.3 定时器线程
5.4 SystemBolt
5.5 Metrics Bolt
5.6 Shared Executor
5.7 Metrics执行流程
Message Passing
basic concepts
Message Passing
7.1 Tuple接收
7.1.1 worker创建接收线程
7.1.2 worker从socket接收消息
7.1.3 disruptor在线程之间进行消息传递
7.1.4 消息被executor处理
7.2 Tuple发送
7.2.1 IConnection
7.2.2 grouping
Reliability Mechanism
Reliability Mechanism
8.1 Acking Framework
Trident Topology
9.1 应用举例
9.2 TridentTopology创建过程详解
9.2.1 引言
9.2.2 TridentTopoloy
9.2.3 newStream
9.2.4 each
9.2.5 partitionPersist
9.2.6 build
9.2.7 grouping
9.3 Storm Topology的ack机制
9.4 TridentTopology调用关系
9.4.1 处理结束的判断依据
9.5 seeder tuple的状态机








storm源码走读.zip (396.89 KB, 下载次数: 34, 售价: 2 云币)

2014-6-21 14:04 上传

点击文件名下载附件

正在学习，感谢，多多提供storm资料~

不错的资料，谢谢分享~~~~~~~

thanks a lot