首页 > 代码库 > 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