Storm-源碼分析彙總

Storm Features

Storm 簡介

Storm Topology的併發度

Storm - Guaranteeing message processing

Storm - Transactional-topologies

Twitter Storm – DRPC

Storm 多語言支持

 

Storm Starter

Storm starter - Overview

Storm starter – SingleJoinExample

Storm starter – RollingTopWords

 

Storm Topology

Storm-源碼分析-Topology Submit-Client

Storm-源碼分析-Topology Submit-Nimbus

Storm-源碼分析-Topology Submit-Nimbus-mk-assignments

Storm-源碼分析- Component ,Executor ,Task之間關係

Storm-源碼分析- Scheduler

    

Storm-源碼分析-Topology Submit-Supervisor

Storm-源碼分析-Topology Submit-Worker

    

Storm-源碼分析-Topology Submit-Executor

Storm-源碼分析-Topology Submit-Executor-mk-threads

    

Storm-源碼分析-Topology Submit-Task

Storm-源碼分析-Topology Submit-Task-TopologyContext (backtype.storm.task)

 

Storm Modules

Storm-源碼分析- Messaging (backtype.storm.messaging)

Storm-源碼分析-Streaming Grouping (backtype.storm.daemon.executor)

Storm-源碼分析- hook (backtype.storm.hooks) 

Storm-源碼分析-Stats (backtype.storm.stats)

Storm-源碼分析- metric

Storm-源碼分析-acker (backtype.storm.daemon.acker)

 

Storm中用到的Utils (能夠獨立使用)

Storm-源碼分析- Thrift的使用

Storm-源碼分析- Storm中Zookeeper的使用

Storm-源碼分析- Disruptor在storm中的使用

Storm-源碼分析-LocalState (backtype.storm.utils)

Storm-源碼分析- timer (backtype.storm.timer)

Storm-源碼分析-EventManager (backtype.storm.event)

   

Storm的使用, Bolt和Spout

Storm-源碼分析- spout (backtype.storm.spout)

Storm-源碼分析- bolt (backtype.storm.task)