本文主要是介绍Storm的Spout和Bolt中的方法,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一、Spout中的方法
1.open
当一个Task被初始化的时候会调用此open方法。一般都会在此方法中对发送Tuple的对象SpoutOutputCollector和配置对象TopologyContext初始化。
2.declareOutputFields
此方法用于声明当前Spout的Tuple发送流。Stream流的定义是通过OutputFieldsDeclare.declareStream方法完成的,其中的参数包括了发送的域Fields。
这篇关于Storm的Spout和Bolt中的方法的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!