org.apache.storm.redis.common.adapter

## Class RedisCommandsAdapterJedisCluster

- java.lang.Object
- - org.apache.storm.redis.common.adapter.RedisCommandsAdapterJedisCluster

- All Implemented Interfaces:
    Closeable, AutoCloseable, RedisCommands

      public class RedisCommandsAdapterJedisCluster
      extends Object
      implements RedisCommands, Closeable

  Adapter class to make JedisCluster instance play with BinaryRedisCommands interface.

- - ### Constructor Summary

    Constructors
    Constructor and Description
    `RedisCommandsAdapterJedisCluster(redis.clients.jedis.JedisCluster jedisCluster)`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `close()`
    `Long` | `del(byte[] key)`
    `Long` | `del(String key)`
    `Boolean` | `exists(byte[] key)`
    `boolean` | `exists(String key)`
    `Long` | `hdel(byte[] key, byte[]... fields)`
    `byte[]` | `hget(byte[] key, byte[] field)`
    `Map<byte[],byte[]>` | `hgetAll(byte[] key)`
    `Map<String,String>` | `hgetAll(String key)`
    `String` | `hmset(byte[] key, Map<byte[],byte[]> fieldValues)`
    `String` | `hmset(String key, Map<String,String> fieldValues)`
    `redis.clients.jedis.ScanResult<Map.Entry<byte[],byte[]>>` | `hscan(byte[] key, byte[] cursor, redis.clients.jedis.ScanParams params)`
    `String` | `rename(byte[] oldkey, byte[] newkey)`
    `String` | `rename(String oldkey, String newkey)`

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Constructor Detail

    - #### RedisCommandsAdapterJedisCluster

          public RedisCommandsAdapterJedisCluster(redis.clients.jedis.JedisCluster jedisCluster)

  - ### Method Detail

    - #### hget

          public byte[] hget(byte[] key,
                             byte[] field)

      Specified by:
        `hget` in interface `RedisCommands`

    - #### exists

          public Boolean exists(byte[] key)

      Specified by:
        `exists` in interface `RedisCommands`

    - #### exists

          public boolean exists(String key)

      Specified by:
        `exists` in interface `RedisCommands`

    - #### hmset

          public String hmset(byte[] key,
                              Map<byte[],byte[]> fieldValues)

      Specified by:
        `hmset` in interface `RedisCommands`

    - #### hmset

          public String hmset(String key,
                              Map<String,String> fieldValues)

      Specified by:
        `hmset` in interface `RedisCommands`

    - #### hgetAll

          public Map<byte[],byte[]> hgetAll(byte[] key)

      Specified by:
        `hgetAll` in interface `RedisCommands`

    - #### hgetAll

          public Map<String,String> hgetAll(String key)

      Specified by:
        `hgetAll` in interface `RedisCommands`

    - #### hdel

          public Long hdel(byte[] key,
                           byte[]... fields)

      Specified by:
        `hdel` in interface `RedisCommands`

    - #### del

          public Long del(byte[] key)

      Specified by:
        `del` in interface `RedisCommands`

    - #### del

          public Long del(String key)

      Specified by:
        `del` in interface `RedisCommands`

    - #### rename

          public String rename(byte[] oldkey,
                               byte[] newkey)

      Specified by:
        `rename` in interface `RedisCommands`

    - #### rename

          public String rename(String oldkey,
                               String newkey)

      Specified by:
        `rename` in interface `RedisCommands`

    - #### hscan

          public redis.clients.jedis.ScanResult<Map.Entry<byte[],byte[]>> hscan(byte[] key,
                                                                                byte[] cursor,
                                                                                redis.clients.jedis.ScanParams params)

      Specified by:
        `hscan` in interface `RedisCommands`

    - #### close

          public void close()
                     throws IOException

      Specified by:
        `close` in interface `Closeable`
      Specified by:
        `close` in interface `AutoCloseable`
      Throws:
        `IOException`

Copyright © 2021 The Apache Software Foundation. All rights reserved.