Storm实时处理问题

想请教一下，storm如何从日志中统计过去十分钟内同一ip的个数？

leegh1992 · 发表于 2016-1-6 00:27:18

比如现在是7点，那么它统计的是6：50-7：00
如果现在是7点01分，那么就应该统计6:51-7:01

jlon · 发表于 2016-1-7 14:25:17

使用maven编译storm_starter源码
下载：git clone https://github.com/nathanmarz/storm-starter.git
里面有时间窗口处理的例子，类名是：RollingTopWords（求时间滑动窗口内的单词的数量）

leegh1992 · 发表于 2016-1-7 21:54:37

jlon 发表于 2016-1-7 14:25
使用maven编译storm_starter源码
下载：git clone https://github.com/nathanmarz/storm-starter.git
里 ...

嗯嗯，谢谢你~

图文精华