Bolt接口各個方法的執行順序

在storm-user中看到的一個關於Storm Bolt內部實現的執行順序的問題, 以爲對理解Bolt內部實現有幫助, 記錄一下.

prepare方法在worker初始化task的時候調用. 

execute方法在每次有tuple進來的時候被調用 

cleanup實際上僅用於本地模式(local mode), 在集羣模式(cluster mode)下該方法很難保證每次被正確執行. 

declearOutputFields方法僅在有新的topology提交到服務器, 用來決定輸出內容流的格式(至關於定義spout/bolt之間傳輸stream的name:value格式), 在topology執行的過程當中並不會被調用.