首页 > 代码库 > storm每隔一段时间发送tuple
storm每隔一段时间发送tuple
TickTuple可以满足每隔一段时间发送tuple,"__system" component会定时往task发送 "__tick" stream的tuple,
发送频率由TOPOLOGY_TICK_TUPLE_FREQ_SECS来配置, 可以在default.ymal里面配置,
也可以在代码里面通过getComponentConfiguration()来进行配置。
代码里面配置如下
public Map<String, Object> getComponentConfiguration() {
Map<String, Object> conf = new HashMap<String, Object>();
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 1); //间隔1s
return conf;
}
public static boolean isTickTuple(Tuple tuple) {
return tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID) //SYSTEM_COMPONENT_ID == "__system"
&& tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID); //SYSTEM_TICK_STREAM_ID == "__tick"
}
配置完成后, storm就会定期的往task发送ticktuple
只需要通过isTickTuple来判断是否为tickTuple, 就可以完成定时触发的功能
public final void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
if (!isTickTuple(tuple)) { }
}
storm每隔一段时间发送tuple