From 0034f98c27460949e4411b5b7e652f2944a52528 Mon Sep 17 00:00:00 2001 From: Colin Surprenant Date: Thu, 17 Nov 2011 13:26:33 -0500 Subject: [PATCH] fix examples --- examples/simple/exclamation_topology.rb | 2 +- examples/simple/split_sentence_bolt.rb | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/examples/simple/exclamation_topology.rb b/examples/simple/exclamation_topology.rb index f0202e7..b992d42 100644 --- a/examples/simple/exclamation_topology.rb +++ b/examples/simple/exclamation_topology.rb @@ -11,7 +11,7 @@ class ExclamationTopology < RedStorm::SimpleTopology source TestWordSpout, :shuffle end - bolt ExclamationBolt, :id => :exclamation_bolt2, :parallelism => 2 do + bolt ExclamationBolt, :id => :ignore, :parallelism => 2 do source ExclamationBolt, :shuffle end diff --git a/examples/simple/split_sentence_bolt.rb b/examples/simple/split_sentence_bolt.rb index e61670f..bc20033 100644 --- a/examples/simple/split_sentence_bolt.rb +++ b/examples/simple/split_sentence_bolt.rb @@ -10,19 +10,19 @@ class SplitSentenceBolt < RedStorm::SimpleBolt # block declaration style no auto-emit # # on_receive :emit => false do |tuple| - # tuple.getString(0).split(' ').each{|w| emit(w)} + # tuple.getString(0).split(' ').each{|w| unanchored_emit(w)} # end # alternate declaration style using on_receive method # - # on_receive :emit => false + # on_receive :emit => true # def on_receive(tuple) # tuple.getString(0).split(' ').map{|w| [w]} # end # alternate declaration style using any specific method # - # on_receive :my_method, :emit => false + # on_receive :my_method, :emit => true # def my_method(tuple) # tuple.getString(0).split(' ').map{|w| [w]} # end