Storm部分:代碼模板【Java版純代碼】

總結:構成部分:java Spout部分:繼承BaseRichSpout類,實現裏邊的三個方法:nextTuple,open,declareOutPutFields.主要的方法在nexttuple中寫,打包成集合的形式,在這個方法中用emit發送,同時在declareOutPutFields也有發送ide Bolt方法:繼承BaseRichBolt類,實現內部的三個方法:execute,open,
相關文章
相關標籤/搜索