首页
Python
Java
前端
数据库
Linux
Chatgpt专题
开发者工具箱
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
阅读更多...