组成:
Topology是Storm里的最高抽象概念,相当于Hadoop里的MapReduce,
Topology(流转换图)由Spouts和Bolts组成。
Spout创建Stream,Stream由无限的Tuple(元组)构成。
Bolts接收Spout流出的Tuple并进行处理,处理后生成的新的Tuple可以流向下一个Bolt,
也可以直接结束。
架构:
用户提交Topology到
Storm上后会由Master上运行的Nimbus进行任务调度和监控,Nimbus将分配的任务存储到
Zookeeper里,Supervisor负责监听任务,会从Zookeeper中获取到分配的
任务,获取到任务后Worker上的Task负责任务的具体执行。
可参考: