一、通过发送系统级别的Tuple进行计算该时间段的数据
设置发送系统级别tuple的时间间隔
Config conf = new Config();
//设置定时发送系统级别的tuple.
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 5);
这样每个Bolt在设置的时间间隔都会收到一个系统级别的tuple,我们对这个tuple进行判断, 接收到了,就表示时间间隔到了, 我们可以将这个时间间隔内统计的数据做相应的操作(入库)。
@Override
public Map getComponentConfiguration() {
Map conf = new HashMap();
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 5);;
return conf;
}