1. IComponent接口
有两个方法：
public class component implements IComponent{
@Override
public void declareOutputFields(OutputFieldsDeclarer arg0) {
}
@Override
public Map<String, Object> getComponentConfiguration() {
return null;
}
}
2. ISpout接口
有七个方法：
public class MySpout implements ISpout{
@Override
public void ack(Object arg0) {
}
@Override
public void activate() {
}
@Override
public void close() {
}
@Override
public void deactivate() {
}
@Override
public void fail(Object arg0) {
}
@Override
public void nextTuple() {
}
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
}
}
3. IBolt接口
共有三个方法：
public class MyBolt implements IBolt{
@Override
public void cleanup() {
}
@Override
public void execute(Tuple tuple) {
}
@Override
public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
}
}
4. 事务接口
IPartitionedTransactionalSpout接口继承自IComponent接口。
IOpaquePartitionedTransactionalSpout接口继承自IComponent接口。
ITransactionalSpout
5. 组件之关系