StormTwitterHashtagTopologyRunner.java

private static TopologyBuilder wireTopology() {
    TopologyBuilder builder = new TopologyBuilder();

	// Twitter API Key
    String consumerKey = "consumerKey";
    String consumerSecret = "consumerSecret";
    String accessToken = "accessToken";
    String accessTokenSecret = "accessTokenSecret";
    String[] keyWords = new String[0];
	
    builder.setSpout("twitter", new TwitterSpout(consumerKey, consumerSecret, accessToken, accessTokenSecret, keyWords));
	
    builder.setBolt("extractHashTag", new ExtractHashTagBolt(), 6).shuffleGrouping("twitter");
    builder.setBolt("rollingCount", new RollingCountBolt(60, 5), 12).fieldsGrouping("extractHashTag", new Fields("word"));
    builder.setBolt("intermediateRanking", new IntermediateRankingsBolt(TOP_N, 5), 6).fieldsGrouping("rollingCount", new Fields("obj"));
    builder.setBolt("totalRanker", new TotalRankingsBolt(TOP_N, 10)).globalGrouping("intermediateRanking");
    builder.setBolt("print",  new PrinterBolt(), 2).shuffleGrouping("totalRanker");

    return builder;
}