2015 年营地
Apache Storm 入门
为 2015 年 BreizhCamp 的 Start with Apache Storm 会议创建的项目。
羊柜台
Sheep-counter 是一种 Storm 拓扑,用于按发送到 Redis pub/sub 的羊的颜色进行排序和计数。
要启动它:
运行bzh.cjuste.breizhcamp.sheepcounter.SheepCounterTopology类
等待消息Ready to receive messages !
运行测试类(在 src/test/java 中) bzh.cjuste.breizhcamp.sheepcounter.SendSheeps
2021-05-31 19:03:43
110KB
Java
1