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

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。