package com.stormadvance.storm_example;

import org.apache.storm.Config;
import org.apache.storm.StormSubmitter;
import org.apache.storm.generated.AlreadyAliveException;
import org.apache.storm.generated.AuthorizationException;
import org.apache.storm.generated.InvalidTopologyException;
import org.apache.storm.topology.TopologyBuilder;

public class SampleStormClusterTopology {
        public static void main(String[] args) throws AlreadyAliveException,
                        InvalidTopologyException {
                // create an instance of TopologyBuilder class
                TopologyBuilder builder = new TopologyBuilder();
                // set the spout class
                builder.setSpout("SampleSpout", new SampleSpout(), 2);
                // set the bolt class
                builder.setBolt("SampleBolt", new SampleBolt(), 4).shuffleGrouping(
                                "SampleSpout");
                Config conf = new Config();
                conf.setNumWorkers(3);
                // This statement submit the topology on remote
                // args[0] = name of topology
                try {
                        StormSubmitter.submitTopology(args[0], conf,
                                        builder.createTopology());
                } catch (AlreadyAliveException alreadyAliveException) {
                        System.out.println(alreadyAliveException);
                } catch (InvalidTopologyException invalidTopologyException) {
                        System.out.println(invalidTopologyException);
                } catch (AuthorizationException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }

}

看看      

不知是啥子，看看

看看

马克一下

谢谢分享

thanks                                      

谢谢分享

Ankit Jain]Mast

谢谢！

不错的好书

哈哈

好奇看看

心情不好很郁闷！

谢谢分享

谢谢分享