storm总结

  *storm的开发 开发spout类(定义一个类型实现BaseRichSpout抽象类,然后实现其nextTuple方法和open方法) 开发bolt类(定一个类型实现BaseRichBolt抽象类,然后实现其execute方法,declareOutputFields方法) 把spout类和bolt类组装在一块形成一个topology(使用TopologyBuilder来创建topology对
相关文章
相关标签/搜索