storm編程-項目實戰篇-wordcount程序

部分轉載: (1)Open() 是初始化方法 (2)close() 在該spout關閉前執行,但是並不能得到保證其一定被執行,kill -9時不執行,Storm kill {topoName} 時執行 (3)activate() 當Spout已經從失效模式中**時被調用。該Spout的nextTuple()方法很快就會被調用。 (4)deactivate () 當Spout已經失效時被調用。在Sp
相關文章
相關標籤/搜索