复制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. |
喜欢
讨厌