SplitSentence bolt in Java

WordCountTopology.java

    public static class SplitSentence implements IRichBolt {

    	private OutputCollector collector;

        @Override
        public void declareOutputFields(OutputFieldsDeclarer declarer) {
            declarer.declare(new Fields("word"));
        }

		@Override
		public void prepare(Map stormConf, TopologyContext context,
				OutputCollector collector) {
			this.collector = collector;
		}

		@Override
		public void execute(Tuple input) {
			String val = input.getString(0);
			for (String word : val.split(" ")) {
				collector.emit(input, new Values(word));
			}
			collector.ack(input);
		}

		@Override
		public void cleanup() {
		}
    }