Storm Component基本抽象类BaseComponent

203 阅读 0 评论 134 点赞

我是靠谱客的博主复杂电脑，这篇文章主要介绍Storm Component基本抽象类BaseComponent，现在分享给大家，希望可以做个参考。

2019独角兽企业重金招聘Python工程师标准>>>

BaseComponent

BaseComponent实现了IComponent接口。

package org.apache.storm.topology.base;
import org.apache.storm.topology.IComponent;
import java.util.Map;
public abstract class BaseComponent implements IComponent {
    @Override
    public Map<String, Object> getComponentConfiguration() {
        return null;
    }    
}

BaseRichSpout

BaseRichSpout抽象类继承了BaseComponent类并实现了IRichSpout接口。

package org.apache.storm.topology.base;
import org.apache.storm.topology.IRichSpout;
public abstract class BaseRichSpout extends BaseComponent implements IRichSpout {
    @Override
    public void close() {
    }
    @Override
    public void activate() {
    }
    @Override
    public void deactivate() {
    }
    @Override
    public void ack(Object msgId) {
    }
    @Override
    public void fail(Object msgId) {
    }
}

BaseRichBolt

BaseRichBolt抽象类继承BaseComponent类并实现IRichBolt接口。

package org.apache.storm.topology.base;
import org.apache.storm.topology.IRichBolt;
public abstract class BaseRichBolt extends BaseComponent implements IRichBolt {
    @Override
    public void cleanup() {
    }    
}

BaseBasicBolt

BaseBasicBolt抽象类继承BaseComponent类并实现IBasicBolt接口。

package org.apache.storm.topology.base;
import org.apache.storm.task.TopologyContext;
import org.apache.storm.topology.IBasicBolt;
import java.util.Map;
public abstract class BaseBasicBolt extends BaseComponent implements IBasicBolt {
    @Override
    public void prepare(Map<String, Object> topoConf, TopologyContext context) {
    }
    @Override
    public void cleanup() {
    }    
}

转载于:https://my.oschina.net/yulongblog/blog/1509499