SampleBolt.java

public class SampleBolt extends BaseRichBolt {

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

  @Override
  public void execute(Tuple input) {
    String firstName = input.getStringByField("firstName");
    double height = input.getDoubleByField("height");
    Object complexObject = (Object) input.getValueByField("complexObject");
    if(height > 5.0)
      collector.emit(new Values(firstName.toLowerCase()));
    collector.ack(input);
  }

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

SampleSpout.java

public class SampleSpout extends BaseRichSpout {

  private SpoutOutputCollector collector;
	
	@Override
	public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
		this.collector = collector;
		
		/*
		 * Connect to your data source here
		 * Eg. Run a query and store a reference to the cursor
		 */
		
	}

	@Override
	public void nextTuple() {
		
		/*
		 * Iterate through the stored cursor ref and push out
		 * one "row" into the collector as a Tuple
		 */
		collector.emit("default", new Values("John", 5.5, new Object()));
	}

	@Override
	public void declareOutputFields(OutputFieldsDeclarer declarer) {
		/*
		 * Schema declaration of the stream
		 */
		declarer.declareStream("default", new Fields("firstName", "height", "complexObject"));
	}
}

SampleTopology.java

public class SampleTopology {  
	public static void main(String[] args) {
		Config config = new Config();
		
		TopologyBuilder b = new TopologyBuilder();
		b.setSpout("sampleSpoutId", new SampleSpout(), 1);
		b.setBolt("sampleBoltId", new SampleBolt(), 1).shuffleGrouping("sampleSpoutId");
		
		final LocalCluster cluster = new LocalCluster();
		cluster.submitTopology("SampleTopologyName", config, b.createTopology());
		
		Runtime.getRuntime().addShutdownHook(new Thread()	{
			@Override
			public void run()	{
				cluster.killTopology("SampleTopologyName");
				cluster.shutdown();
			}
		});
	}
}