storm API.docx

接口：IRichSpout来自：backtype.storm.topology包其父类：IComponent,ISpout,Serializable实现此接口的类：BaseRichSpout,ClojureSpout,DRPCSpout,FeederSpout,FixedTupleSpout,MasterBatchCoordinator,RichShellSpout,RichSpoutBatchTriggerer,SpoutTracker,TestPlannerSpout,TestWordSpout,TransactionalSpoutCoordinator继承自接口backtype.storm.spout.ISpout的方法：ack,activate,close,deactivate,fail,nextTuple,open继承自接口backtype.storm.topology.IComponent的方法：declareOutputFields,getComponentConfiguration=BaseRichSpout类:来自：其子类：DRPCSpout,FeederSpout,MasterBatchCoordinator,SpoutTracker,TestPlannerSpout,TestWordSpout,TransactionalSpoutCoordinator定义：public abstract class BaseRichSpout extends BaseComponent implements IRichSpout 即：继承自BaseComponet实现了IRichSpout接口方法：继承自接口backtype.storm.topology.base.BaseComponent的方法：getComponentConfiguration继承自接口java.lang.Object的方法：clone,equals,finalize,getClass,hashCode,notify,notifyAll,toString,wait,wait,wait继承自接口backtype.storm.spout.ISpout的方法：nextTuple,open继承自接口backtype.storm.topology.IComponent的方法：declareOutputFields,getComponentConfiguration总结：BaseRichSpout类虽然继承了IRichSpout接口，但是并没有实现接口中所有方法。IRichSpout接口方法集锦：ack, activate, close, deactivate, fail, nextTuple, open，declareOutputFields, getComponentConfigurationBaseRichSpout类方法集锦：getComponentConfiguration，clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait，nextTuple, open，declareOutputFields, #IRichBolt接口：来自：backtype.storm.topology包其父类：IBolt,IComponent,Serializable实现此接口的类：BaseRichBolt,BasicBoltExecutor,BatchBoltExecutor,BoltTracker,ClojureBolt,CoordinatedBolt,JoinResult,KeyedFairBolt,ReturnResults,RichShellBolt,TestAggregatesCounter,TestGlobalCount,TestPlannerBolt,TransactionalSpoutBatchExecutor,TridentBoltExecutor,TupleCaptureBolt方法：继承自接口backtype.storm.task.IBolt的方法：cleanup,execute,prepare继承自接口backtype.storm.topology.IComponent的方法：declareOutputFields,getComponentConfiguration=BaseBasicBolt类：来自：所有被继承的接口：IBasicBolt,IComponent,Serializable直接的子类：BatchProcessWord,BatchRepeatA,IdentityBolt,PrepareBatchBolt,PrepareRequest,TestConfBolt,TestWordCounter定义：public abstract class BaseBasicBolt extends BaseComponentimplements IBasicBolt自己的方法：void cleanup()void prepare(Map stormConf,TopologyContext context)继承自backtype.storm.topology.base.BaseComponent的方法：getComponentConfiguration继承自java.lang.Object的方法：clone,equals,finalize,getClass,hashCode,notify,notifyAll,toString,wait,wait,wait继承自backtype.storm.topology.IBasicBolt的方法：execute继承自backtype.storm.topology.IComponent的方法：declareOutputFields,getComponentConfiguration总结：BaseBasicBolt继承了IRichBolt接口，但是并没有继承其所有方法。IRichBolt接口方法集锦：cleanup,execute,prepare，declareOutputFields , getComponentConfigurationBaseBasicBolt类接口集锦：cleanup，prepare，getComponentConfiguration，clone,equals,finalize,getClass,hashCode,notify,notifyAll,toString,wait,wait,wait，execute，declareOutputFields #SpoutOutputCollector类：来自：继承自此接口：ISpoutOutputCollector定义：public class SpoutOutputCollector extends Object implements ISpoutOutputCollector这个输出收集器提供了一个面向从IRichSpout接口发射tuples的API接口，其中SpoutOutputCollector的输出收集器和针对IRichBolt的输出收集器主要的不同之处在于此收集器可以使spouts以ids的形式贴上标签，以便它们之后被追踪和结束，这样使得Storm的API接口的spout组件能够保证每个消息完全被执行至少一次。构造器:SpoutOutputCollector(ISpoutOutputCollectordelegate)方法：List emit(List tuple)给带有空message id缺省的输出流发送一个tupleList emit(List tuple, Object messageId)向带有给定message ID的缺省的输出流发送一个新的tupleList emit(String streamId, List tuple,Object messageId)向带有给定message id具体数据流发送一个tuplevoid emitDirect(int taskId,List tuple)向带有给定message ID的具体数据流发送一个新的tuplevoid emitDirect(inttaskId,Listtuple,ObjectmessageId)给缺省的数据流下的具体的task发送一个tuplevoid emitDirec