Permalink
Browse files

fix TopologyBuilder docs

  • Loading branch information...
1 parent b704893 commit 8aed7da5af3a2794f3be7e79524615548a02c767 @nathanmarz committed Dec 18, 2011
Showing with 14 additions and 14 deletions.
  1. +14 −14 src/jvm/backtype/storm/topology/TopologyBuilder.java
@@ -25,13 +25,13 @@
* <pre>
* TopologyBuilder builder = new TopologyBuilder();
*
- * builder.setSpout(1, new TestWordSpout(true), 5);
- * builder.setSpout(2, new TestWordSpout(true), 3);
- * builder.setBolt(3, new TestWordCounter(), 3)
- * .fieldsGrouping(1, new Fields("word"))
- * .fieldsGrouping(2, new Fields("word"));
- * builder.setBolt(4, new TestGlobalCount())
- * .globalGrouping(1);
+ * builder.setSpout("1", new TestWordSpout(true), 5);
+ * builder.setSpout("2", new TestWordSpout(true), 3);
+ * builder.setBolt("3", new TestWordCounter(), 3)
+ * .fieldsGrouping("1", new Fields("word"))
+ * .fieldsGrouping("2", new Fields("word"));
+ * builder.setBolt("4", new TestGlobalCount())
+ * .globalGrouping("1");
*
* Map conf = new HashMap();
* conf.put(Config.TOPOLOGY_WORKERS, 4);
@@ -46,13 +46,13 @@
* <pre>
* TopologyBuilder builder = new TopologyBuilder();
*
- * builder.setSpout(1, new TestWordSpout(true), 5);
- * builder.setSpout(2, new TestWordSpout(true), 3);
- * builder.setBolt(3, new TestWordCounter(), 3)
- * .fieldsGrouping(1, new Fields("word"))
- * .fieldsGrouping(2, new Fields("word"));
- * builder.setBolt(4, new TestGlobalCount())
- * .globalGrouping(1);
+ * builder.setSpout("1", new TestWordSpout(true), 5);
+ * builder.setSpout("2", new TestWordSpout(true), 3);
+ * builder.setBolt("3", new TestWordCounter(), 3)
+ * .fieldsGrouping("1", new Fields("word"))
+ * .fieldsGrouping("2", new Fields("word"));
+ * builder.setBolt("4", new TestGlobalCount())
+ * .globalGrouping("1");
*
* Map conf = new HashMap();
* conf.put(Config.TOPOLOGY_WORKERS, 4);

0 comments on commit 8aed7da

Please sign in to comment.