加载中
storm 1.0以后的新版本 滑动窗口的实现及原理

简单的演示如何使用storm1.0实现滑动窗口的功能,先编写spout类,RandomSentenceSpout负责发送一个整形数值,数值每次发送都会自动加一,且RandomSentenceSpout固定每隔两秒向bolt发送一次数据...

2017/09/02 16:01
35
Storm1.0 以前的老版本 实现滑动窗口计数和TopN排序

http://www.michael-noll.com/blog/2013/01/18/implementing-real-time-trending-topics-in-storm/...

2017/09/02 15:59
7
IWindowedBolt.java

storm1.1.1的窗口接口

2017/09/02 14:16
1
BaseWindowedBolt.java

storm1.1.1的窗口bolt的核心代码

没有更多内容

加载失败,请刷新页面

返回顶部
顶部