1.背景
需要在bolt中定时执行某些操作
2.方法
都是利用系统自带的定时tuple来完成,相当于系统自动发一个带有特殊标记的tuple,然后自己在bolt中判断,若为此特殊tuple,执行定时函数。
(1)如果所有bolt都需要定时,可在topology入口处通过config设置
(2)如果只有某一类bolt需要定时,可在该bolt内部override getComponetConfiguration方法设置
3.实现
(1)在topology入口处
- conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60);// 设置本Bolt定时发射数据
在各个bolt中使用下面代码判断是否是触发定时
- tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID)
(2)bolt内部
- @Override
- public Map<String, Object> getComponentConfiguration() {
- // configure how often a tick tuple will be sent to ParseBolt
- Config conf = new Config();
- conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, TOPOLOGY_TICK_TUPLE_FREQ_SECS);
- return conf;
- }
执行函数内:
- public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
- if (tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID) &&
- tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID)) {
- //some things to do
- return;
- }
- }
4.注意事项
(1)一定注意区分自己的需求是第一种还是第二种
(2)接到定时tuple并处理后,记得执行return;