Storm Component基本抽象类

原创
2017/08/14 09:31
阅读数 47

 

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

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部