Topology
一个topology 是 spouts 和 bolts 组成的图，通过stream groupings 将图中的spouts和bolts连接起来。
拓扑结构示意图
Stream
stream，消息流。一个消息流是一个没有边界的tuple序列，而这些tuple序列会以一种分布的方式进行创建和处理。
tuple的类型可以为：integer，short，byte，string，double，float，boolean，byte array 或者自定义（需要手动实现序列化器）同时实现spouts 和 blots 的接口来处理stream和业务逻辑
Spout
spouts是stream消息流中消息的生产者。一般是通过在外部读入数据并且向topo中发送tuple。
Bolts
bolts负责对消息进行处理，如过滤，聚合，查询数据库等
网友评论