spout专题

Storm的Spout和Bolt中的方法

一、Spout中的方法 1.open 当一个Task被初始化的时候会调用此open方法。一般都会在此方法中对发送Tuple的对象SpoutOutputCollector和配置对象TopologyContext初始化。 2.declareOutputFields    此方法用于声明当前Spout的Tuple发送流。Stream流的定义是通过OutputFieldsDecl

spout的生命周期

1、在定义Topology实例过程中,定义好Spout实例和Bolt实例 2、在提交Topology实例给Nimbus的过程中,会调用TopologyBuilder实例的createTopology()方法,以获取定义的Topology实例。在运行createTopology()方法的过程中,会去调用Spout和Bolt实例上的declareOutputFields()方法和getCompo