From 8221ab2b90c93cd4e5d755ff42dd02f3d18905ff Mon Sep 17 00:00:00 2001 From: Colin Surprenant Date: Wed, 15 May 2013 13:48:47 -0400 Subject: [PATCH] new hello world example --- examples/simple/hello_world_topology.rb | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 examples/simple/hello_world_topology.rb diff --git a/examples/simple/hello_world_topology.rb b/examples/simple/hello_world_topology.rb new file mode 100644 index 0000000..63a1b2d --- /dev/null +++ b/examples/simple/hello_world_topology.rb @@ -0,0 +1,22 @@ +require 'red_storm' + +class HelloWorldSpout < RedStorm::SimpleSpout + on_init {@words = ["hello", "world"]} + on_send {@words.shift unless @words.empty?} +end + +class HelloWorldBolt < RedStorm::SimpleBolt + on_receive :emit => false do |tuple| + log.info(tuple.getString(0)) + end +end + +class HelloWorldTopology < RedStorm::SimpleTopology + spout HelloWorldSpout do + output_fields :word + end + + bolt HelloWorldBolt do + source HelloWorldSpout, :global + end +end \ No newline at end of file