Twitter利用Storm系统处理实时大数据

复制TopologyBuilder builder = new TopologyBuilder();   builder.setSpout("spout",系统 new RandomSentenceSpout(), 5);   builder.setBolt("map", new SplitSentence(), 4)   .shuffleGrouping("spout");   builder.setBolt("reduce", new WordCount(), 8)   .fieldsGrouping("map", new Fields("word"));   Config conf = new Config();   conf.setDebug(true);   LocalCluster cluster = new LocalCluster();   cluster.submitTopology("word-count", conf, builder.createTopology());   Thread.sleep(10000);   cluster.shutdown();  1.2.3.4.5.6.7.8.9.10.11.12.