《storm分布式实时计算模式》源码

《storm分布式实时计算模式》源码

package storm.blueprints.chapter1.v1;

import backtype.storm.task.OutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.baseRichBolt;
import backtype.storm.tuple.Tuple;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class ReportBolt extends baseRichBolt {

    private HashMap counts = null;

    public void prepare（Map config TopologyContext context OutputCollector collector） {
        this.counts = new HashMap（）;
    }

    public void execute（Tuple tuple） {
        String word = tuple.getStringByField（“word“）;
        Long count = tuple.getLongByField（“count“）;
        this.counts.put（word count）;
    }

    public void declareOutputFields（OutputFieldsDeclarer declarer） {
        // this bolt does not emit anything
    }

    @Override
    public void cleanup（） {
        System.out.println（“--- FINAL COUNTS ---“）;
        List keys = new ArrayList（）;
        keys.addAll（this.counts.keySet（））;
        Collections.sort（keys）;
        for （String key : keys） {
            System.out.println（key + “ : “ + this.counts.get（key））;
        }
        System.out.println（“--------------“）;
    }
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2014-03-24 17:47  8294OS_Code\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\
     文件        1348  2014-03-24 16:48  8294OS_Code\Chapter01\.classpath
     文件         661  2014-03-24 16:48  8294OS_Code\Chapter01\.project
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\.settings\
     文件         120  2014-03-24 16:48  8294OS_Code\Chapter01\.settings\org.eclipse.core.resources.prefs
     文件         238  2014-03-24 16:48  8294OS_Code\Chapter01\.settings\org.eclipse.jdt.core.prefs
     文件          86  2014-03-24 16:48  8294OS_Code\Chapter01\.settings\org.eclipse.m2e.core.prefs
     文件        5494  2014-03-24 16:48  8294OS_Code\Chapter01\Chapter1 （1）.iml
     文件        2155  2014-03-24 16:48  8294OS_Code\Chapter01\pom.xml
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\
     文件        1339  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\ReportBolt.java
     文件        1194  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\SentenceSpout.java
     文件         958  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\SplitSentenceBolt.java
     文件        1167  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\WordCountBolt.java
     文件        1731  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\WordCountTopology.java
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v2\
     文件        1844  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v2\WordCountTopology.java
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\
     文件        1176  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\SentenceSpout.java
     文件        1844  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\WordCountTopology.java
     文件        1946  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\WordCountTopologyBroken.java
     目录           0  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\
     文件        1497  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\ReportBolt.java
     文件        1696  2014-03-24 16:48  8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\SentenceSpout.java
............此处省略292个文件信息