STORM 定时任务
STORM 定时任务
吹比龙 发表于1年前
STORM 定时任务
  • 发表于 1年前
  • 阅读 81
  • 收藏 0
  • 点赞 0
  • 评论 0

新睿云服务器60天免费使用,快来体验!>>>   

摘要: STORM定时任务实例

1、重写 IComponent的getComponentConfiguration()方法

 @Override
    public Map<String, Object> getComponentConfiguration() {
        Config conf = new Config();
        // 此作用为定时3分钟一次请求
        conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 3 * 60);
        return conf;

    }

2、在bolt的execute()方法区分Tuple类型

 @Override
    public void execute(Tuple input, BasicOutputCollector collector) {
// 判断是否是定时请求的tuple
            if (TupleUtils.isTick(input)) {
                // 做定时任务的事
                return;// 别忘了
            } else {
                // ****
                collector.emit(new Values(yshp,msg));
            }
}

 

标签: Storm定时任务
  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 2
博文 103
码字总数 28922
×
吹比龙
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: