一個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
相關文章
相關標籤/搜索