Storm Component基本抽象类

时间 2019-11-10

原文原文链接

BaseComponent

BaseComponent实现了IComponent接口。java

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接口。apache

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接口。ide

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接口。spa

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() {
    }    
}