storm介绍
个性化推荐系统,视频推荐,商品推荐等分布式可扩展高可靠性编程模型简单高效实时storm是twitter开源的一个分布式实时计算系统使用场景:数据的实时分析,持续计算,分布式RPC等常用的类:BaseRichSpout(消息生产者)BaseRichBolt(消息处理者)TopologyBuilder(拓扑构建器)Values(将数据存放到Values,发生到下
·
个性化推荐系统,视频推荐,商品推荐等
- 分布式
- 可扩展
- 高可靠性
- 编程模型简单
- 高效实时
storm是twitter开源的一个分布式实时计算系统
使用场景:数据的实时分析,持续计算,分布式RPC等
常用的类:
BaseRichSpout(消息生产者)
BaseRichBolt(消息处理者)
TopologyBuilder(拓扑构建器)
Values(将数据存放到Values,发生到下个组件)
Tuple(发送的数据被封装到Tuple,可以通过tuple接受上个组件发送的消息)
Config(配置)
StormSubmitter/ localCluster (拓扑提交器)
更多推荐
所有评论(0)