經(jīng)由Bolt發(fā)送的的tuple將會傳遞到下一個對應(yīng)的Bolt，在我們的用例中是DBWriterBolt。

DBWriterBolt

經(jīng)過處理的tuple必須被持久化以便于觸發(fā)tigger或者更深層次的使用。DBWiterBolt做了這個持久化的工作并把tuple存入了數(shù)據(jù)庫。表的建立由prepare（）函數(shù)完成，這也將是topology調(diào)用的第一個方法。方法的編碼如Listing Six所示。

Listing Six：建表編碼。

1. public void prepare( Map StormConf, TopologyContext context )   
2. {         
3.     try   

4.  29/47   首頁 上一頁 27 28 29 30 31 32 下一頁 尾頁