大圓那些事

public static class WordCount extends BaseBasicBolt {
　　　　　//記錄每個(gè)單詞及單詞出現(xiàn)的次數(shù)
        Map<String, Integer> counts = new HashMap<String, Integer>();

        @Override
        public void execute(Tuple tuple, BasicOutputCollector collector) {
            String word = tuple.getString(0);
            Integer count = counts.get(word); //提取單詞出現(xiàn)次數(shù)
            if(count==null)
　　　　　　　　　count = 0;
            count++;
            counts.put(word, count); //更新單詞出現(xiàn)次數(shù)
            collector.emit(new Values(word, count)); //發(fā)射統(tǒng)計(jì)結(jié)果
        }

        @Override
        public void declareOutputFields(OutputFieldsDeclarer declarer) {
　　　　　　　declarer.declare(new Fields("word", "count"));
        }
    }