一个storm的完整例子——WordCount

import backtype.storm.spout.SpoutOutputCollector; import backtype.storm.task.TopologyContext; import backtype.storm.topology.base.BaseRichSpout; import backtype.storm.utils.Utils; import backtype.sto
相关文章
相关标签/搜索