From d56be3fc2a16681f0ce30c617bdac0d8bf3245a0 Mon Sep 17 00:00:00 2001 From: Nathan Marz Date: Wed, 25 Jan 2012 22:59:15 -0800 Subject: [PATCH] get rid of richbolt setters in transactionaltopologybuilder --- .../storm/transactional/TransactionalTopologyBuilder.java | 8 -------- test/clj/backtype/storm/transactional_test.clj | 2 +- 2 files changed, 1 insertion(+), 9 deletions(-) diff --git a/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java b/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java index 93c2e51d2..a82aa49d6 100644 --- a/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java +++ b/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java @@ -84,14 +84,6 @@ public BoltDeclarer setBolt(String id, IBasicBolt bolt) { public BoltDeclarer setBolt(String id, IBasicBolt bolt, Integer parallelism) { return setBolt(id, new BasicBoltExecutor(bolt), parallelism, false); } - - public BoltDeclarer setBolt(String id, IRichBolt bolt) { - return setBolt(id, bolt, null); - } - - public BoltDeclarer setBolt(String id, IRichBolt bolt, Integer parallelism) { - return setBolt(id, bolt, parallelism, false); - } private BoltDeclarer setBolt(String id, IRichBolt bolt, Integer parallelism, boolean committer) { Component component = new Component(bolt, parallelism, committer); diff --git a/test/clj/backtype/storm/transactional_test.clj b/test/clj/backtype/storm/transactional_test.clj index 31723cf46..5ee00a6ac 100644 --- a/test/clj/backtype/storm/transactional_test.clj +++ b/test/clj/backtype/storm/transactional_test.clj @@ -340,7 +340,7 @@ "spout" (MemoryTransactionalSpout. data (Fields. ["word" "amt"]) - 3) + 2) 2)) (-> builder