ids are now strings

EqualMedia · Dec 8, 2011 · 52f8628 · 52f8628
1 parent 79acca7
commit 52f8628
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 14 deletions.
diff --git a/examples/native/cluster_word_count_topology.rb b/examples/native/cluster_word_count_topology.rb
@@ -5,9 +5,9 @@
 class ClusterWordCountTopology
   def start(base_class_path, env)
     builder = TopologyBuilder.new
-    builder.setSpout(1, JRubySpout.new(base_class_path, "RandomSentenceSpout"), 5)
-    builder.setBolt(2, JRubyBolt.new(base_class_path, "SplitSentenceBolt"), 4).shuffleGrouping(1)
-    builder.setBolt(3, JRubyBolt.new(base_class_path, "WordCountBolt"), 4).fieldsGrouping(2, Fields.new("word"))
+    builder.setSpout('1', JRubySpout.new(base_class_path, "RandomSentenceSpout"), 5)
+    builder.setBolt('2', JRubyBolt.new(base_class_path, "SplitSentenceBolt"), 4).shuffleGrouping('1')
+    builder.setBolt('3', JRubyBolt.new(base_class_path, "WordCountBolt"), 4).fieldsGrouping('2', Fields.new("word"))
 
     conf = Config.new
     conf.setDebug(true)

diff --git a/examples/native/local_exclamation_topology.rb b/examples/native/local_exclamation_topology.rb
@@ -7,9 +7,9 @@ class LocalExclamationTopology
   def start(base_class_path, env)
     builder = TopologyBuilder.new
 
-    builder.setSpout(1, TestWordSpout.new, 10)     
-    builder.setBolt(2, JRubyBolt.new(base_class_path, "ExclamationBolt"), 3).shuffleGrouping(1)
-    builder.setBolt(3, JRubyBolt.new(base_class_path, "ExclamationBolt"), 2).shuffleGrouping(2)
+    builder.setSpout('1', TestWordSpout.new, 10)     
+    builder.setBolt('2', JRubyBolt.new(base_class_path, "ExclamationBolt"), 3).shuffleGrouping('1')
+    builder.setBolt('3', JRubyBolt.new(base_class_path, "ExclamationBolt"), 2).shuffleGrouping('2')
 
     conf = Config.new
     conf.setDebug(true)

diff --git a/examples/native/local_exclamation_topology2.rb b/examples/native/local_exclamation_topology2.rb
@@ -21,9 +21,9 @@ class LocalExclamationTopology2
   def start(base_class_path, env)
     builder = TopologyBuilder.new
 
-    builder.setSpout(1, TestWordSpout.new, 10)     
-    builder.setBolt(2, JRubyBolt.new(base_class_path, "ExclamationBolt2"), 3).shuffleGrouping(1)
-    builder.setBolt(3, JRubyBolt.new(base_class_path, "ExclamationBolt2"), 2).shuffleGrouping(2)
+    builder.setSpout('1', TestWordSpout.new, 10)     
+    builder.setBolt('2', JRubyBolt.new(base_class_path, "ExclamationBolt2"), 3).shuffleGrouping('1')
+    builder.setBolt('3', JRubyBolt.new(base_class_path, "ExclamationBolt2"), 2).shuffleGrouping('2')
 
     conf = Config.new
     conf.setDebug(true)

diff --git a/examples/native/local_redis_word_count_topology.rb b/examples/native/local_redis_word_count_topology.rb
@@ -43,8 +43,8 @@ def detach_redis_reader
 class LocalRedisWordCountTopology
   def start(base_class_path, env)
     builder = TopologyBuilder.new
-    builder.setSpout(1, JRubySpout.new(base_class_path, "RedisWordSpout"), 1)
-    builder.setBolt(2, JRubyBolt.new(base_class_path, "WordCountBolt"), 3).fieldsGrouping(1, Fields.new("word"))
+    builder.setSpout('1', JRubySpout.new(base_class_path, "RedisWordSpout"), 1)
+    builder.setBolt('2', JRubyBolt.new(base_class_path, "WordCountBolt"), 3).fieldsGrouping('1', Fields.new("word"))
 
     conf = Config.new
     conf.setDebug(true)

diff --git a/examples/native/local_word_count_topology.rb b/examples/native/local_word_count_topology.rb
@@ -5,9 +5,9 @@
 class LocalWordCountTopology
   def start(base_class_path, env)
     builder = TopologyBuilder.new
-    builder.setSpout(1, JRubySpout.new(base_class_path, "RandomSentenceSpout"), 5)
-    builder.setBolt(2, JRubyBolt.new(base_class_path, "SplitSentenceBolt"), 8).shuffleGrouping(1)
-    builder.setBolt(3, JRubyBolt.new(base_class_path, "WordCountBolt"), 12).fieldsGrouping(2, Fields.new("word"))
+    builder.setSpout('1', JRubySpout.new(base_class_path, "RandomSentenceSpout"), 5)
+    builder.setBolt('2', JRubyBolt.new(base_class_path, "SplitSentenceBolt"), 8).shuffleGrouping('1')
+    builder.setBolt('3', JRubyBolt.new(base_class_path, "WordCountBolt"), 12).fieldsGrouping('2', Fields.new("word"))
 
     conf = Config.new
     conf.setDebug(true)