From a50d572515633f7384da0eaeda9d7b23ac6cc935 Mon Sep 17 00:00:00 2001 From: darionyaphet Date: Fri, 10 Jun 2016 16:21:31 +0800 Subject: [PATCH] STORM-1880 : Support EXISTS Command Storm-Redis --- .../java/org/apache/storm/redis/bolt/RedisLookupBolt.java | 4 ++++ .../storm/redis/common/mapper/RedisDataTypeDescription.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java b/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java index 968ade0daf4..a3a8e1b06e4 100644 --- a/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java +++ b/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java @@ -109,6 +109,10 @@ public void execute(Tuple input) { lookupValue = jedisCommand.geopos(additionalKey, key); break; + case EXISTS: + lookupValue = jedisCommand.exists(key); + break; + default: throw new IllegalArgumentException("Cannot process such data type: " + dataType); } diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java b/external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java index 7e5c7851885..5478682aa86 100644 --- a/external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java +++ b/external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java @@ -23,7 +23,7 @@ * RedisDataTypeDescription defines data type and additional key if needed for lookup / store tuples. */ public class RedisDataTypeDescription implements Serializable { - public enum RedisDataType { STRING, HASH, LIST, SET, SORTED_SET, HYPER_LOG_LOG, GEO } + public enum RedisDataType { STRING, HASH, LIST, SET, SORTED_SET, HYPER_LOG_LOG, GEO, EXISTS } private RedisDataType dataType; private String additionalKey;