Storm实现单词统计代码
1 import java.io.File; 2 import java.io.IOException; 3 import java.util.Collection; 4 import java.util.HashMap; 5 import java.util.List; 6 import java.util.Map; 7 import java.util.Map.Entry; 8 9 import org.apache.commons.io.FileUtils; 10 11 import backtype.storm.Config; 12 import backtype.storm.LocalCluster; 13 import backtype.storm.spout.SpoutOutputCollector; 14 import backtype.storm.task.OutputCollector; 15 import backtype.storm.task.TopologyContext; 16 import backtype.storm.topology.OutputFie...


















