Storm部分:代码模板【Java版纯代码】

总结:构成部分:java Spout部分:继承BaseRichSpout类,实现里边的三个方法:nextTuple,open,declareOutPutFields.主要的方法在nexttuple中写,打包成集合的形式,在这个方法中用emit发送,同时在declareOutPutFields也有发送ide Bolt方法:继承BaseRichBolt类,实现内部的三个方法:execute,open,
相关文章
相关标签/搜索