storm编程-项目实战篇-wordcount程序

部分转载: (1)Open() 是初始化方法 (2)close() 在该spout关闭前执行,但是并不能得到保证其一定被执行,kill -9时不执行,Storm kill {topoName} 时执行 (3)activate() 当Spout已经从失效模式中**时被调用。该Spout的nextTuple()方法很快就会被调用。 (4)deactivate () 当Spout已经失效时被调用。在Sp
相关文章
相关标签/搜索