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

标签：

原文地址：http://www.cnblogs.com/leistrong/p/4243474.html