topology_code

gistfile1.txt

TopologyBuilder builder = new TopologyBuilder();
        
        builder.setSpout(1, new RandomUserSpout(), 1);
        
        builder.setBolt(2, new PullData(), 8)
                 .shuffleGrouping(1);
        builder.setBolt(3, new DataStore(), 12)
                 .shuffleGrouping(2);
        
        
        
        Map conf = new HashMap();
        
        conf.put(Config.TOPOLOGY_DEBUG, true);
        conf.put(Config.TOPOLOGY_MAX_TASK_PARALLELISM, 3);
        
        LocalCluster cluster = new LocalCluster();
        cluster.submitTopology("ddcrawler", conf, builder.createTopology());