A sample barebones spout

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("val1", "val2", new Object()));
	}

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