Repository: storm Updated Branches: refs/heads/master bb38f176d -> 0d5d4b129
Remove unused code Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/286c52bb Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/286c52bb Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/286c52bb Branch: refs/heads/master Commit: 286c52bbaea9c83d964ceacac1b44d5815294d3e Parents: a8a0dfd Author: Jungtaek Lim <kabh...@gmail.com> Authored: Wed Mar 25 18:30:52 2015 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Wed Mar 25 18:30:52 2015 +0900 ---------------------------------------------------------------------- .../redis/topology/PersistentWordCount.java | 35 -------------------- 1 file changed, 35 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/286c52bb/external/storm-redis/src/test/java/org/apache/storm/redis/topology/PersistentWordCount.java ---------------------------------------------------------------------- diff --git a/external/storm-redis/src/test/java/org/apache/storm/redis/topology/PersistentWordCount.java b/external/storm-redis/src/test/java/org/apache/storm/redis/topology/PersistentWordCount.java index 14a969d..77c6ee8 100644 --- a/external/storm-redis/src/test/java/org/apache/storm/redis/topology/PersistentWordCount.java +++ b/external/storm-redis/src/test/java/org/apache/storm/redis/topology/PersistentWordCount.java @@ -45,41 +45,6 @@ public class PersistentWordCount { private static final String TEST_REDIS_HOST = "127.0.0.1"; private static final int TEST_REDIS_PORT = 6379; - public static class StoreCountRedisBolt extends AbstractRedisBolt { - private static final Logger LOG = LoggerFactory.getLogger(StoreCountRedisBolt.class); - - public StoreCountRedisBolt(JedisPoolConfig config) { - super(config); - } - - public StoreCountRedisBolt(JedisClusterConfig config) { - super(config); - } - - @Override - public void execute(Tuple input) { - String word = input.getStringByField("word"); - int count = input.getIntegerByField("count"); - - JedisCommands commands = null; - try { - commands = getInstance(); - commands.incrBy(word, count); - } catch (JedisConnectionException e) { - throw new RuntimeException("Unfortunately, this test requires redis-server running", e); - } catch (JedisException e) { - LOG.error("Exception occurred from Jedis/Redis", e); - } finally { - returnInstance(commands); - this.collector.ack(input); - } - } - - @Override - public void declareOutputFields(OutputFieldsDeclarer declarer) { - } - } - public static void main(String[] args) throws Exception { Config config = new Config();