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();