You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pa...@apache.org on 2015/04/01 19:49:46 UTC
[15/45] storm git commit: Remove unused code
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/nimbus-ha-branch
Commit: 286c52bbaea9c83d964ceacac1b44d5815294d3e
Parents: a8a0dfd
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Wed Mar 25 18:30:52 2015 +0900
Committer: Jungtaek Lim <ka...@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();