文件名称：storm-编程入门
文件大小：183KB
文件格式：PDF
更新时间：2024-03-21 15:52:48
storm-编程入门
Spout组件的实现可以通过继承BaseRichSpout类或者其他*Spout类来完成，也可以通过实现IRichSpout接口来实现。需要根据情况实方法有：当一个Task被初始化的时候会调用此open方法。一般都会在此方法中对发送Tuple的对象SpoutOutputCollector和配置对象TopologyContext初始化。示例如下：此方法用于声明当前Spout的Tuple发送流的域名字。Stream流的定义是通过OutputFieldsDeclare.declareStream方法完成的，其中参数为域名。示例如下：此方法定义在BaseComponent类内，用于声明针对当前组件的特