Class RedisCommandsAdapterJedis
java.lang.Object
org.apache.storm.redis.common.adapter.RedisCommandsAdapterJedis
- All Implemented Interfaces:
Closeable
,AutoCloseable
,RedisCommands
Adapter class to make Jedis instance play with BinaryRedisCommands interface.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
del
(byte[] key) exists
(byte[] key) boolean
hdel
(byte[] key, byte[]... fields) byte[]
hget
(byte[] key, byte[] field) Map<byte[],
byte[]> hgetAll
(byte[] key) redis.clients.jedis.resps.ScanResult<Map.Entry<byte[],
byte[]>> hscan
(byte[] key, byte[] cursor, redis.clients.jedis.params.ScanParams params) rename
(byte[] oldkey, byte[] newkey)
-
Constructor Details
-
RedisCommandsAdapterJedis
public RedisCommandsAdapterJedis(redis.clients.jedis.Jedis resource)
-
-
Method Details
-
hget
public byte[] hget(byte[] key, byte[] field) - Specified by:
hget
in interfaceRedisCommands
-
exists
- Specified by:
exists
in interfaceRedisCommands
-
exists
- Specified by:
exists
in interfaceRedisCommands
-
hmset
- Specified by:
hmset
in interfaceRedisCommands
-
hmset
- Specified by:
hmset
in interfaceRedisCommands
-
hgetAll
- Specified by:
hgetAll
in interfaceRedisCommands
-
hgetAll
- Specified by:
hgetAll
in interfaceRedisCommands
-
hdel
- Specified by:
hdel
in interfaceRedisCommands
-
del
- Specified by:
del
in interfaceRedisCommands
-
del
- Specified by:
del
in interfaceRedisCommands
-
rename
- Specified by:
rename
in interfaceRedisCommands
-
rename
- Specified by:
rename
in interfaceRedisCommands
-
hscan
public redis.clients.jedis.resps.ScanResult<Map.Entry<byte[],byte[]>> hscan(byte[] key, byte[] cursor, redis.clients.jedis.params.ScanParams params) - Specified by:
hscan
in interfaceRedisCommands
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-