module RedStorm module Examples class RandomSentenceSpout def initialize @sentences = [ "the cow jumped over the moon", "an apple a day keeps the doctor away", "four score and seven years ago", "snow white and the seven dwarfs", "i am at two with nature" ] end def open(conf, context, collector) @collector = collector end def next_tuple @collector.emit(Values.new(@sentences[rand(@sentences.length)])) end def get_component_configuration end def declare_output_fields(declarer) declarer.declare(Fields.new("word")) end end end end