storm總結

  *storm的開發 開發spout類(定義一個類型實現BaseRichSpout抽象類,然後實現其nextTuple方法和open方法) 開發bolt類(定一個類型實現BaseRichBolt抽象類,然後實現其execute方法,declareOutputFields方法) 把spout類和bolt類組裝在一塊形成一個topology(使用TopologyBuilder來創建topology對
相關文章
相關標籤/搜索