MultiKeyPipelineBase (Jedis 3.6.3 API)

java.lang.Object
- redis.clients.jedis.Queable
- - redis.clients.jedis.PipelineBase
  - - redis.clients.jedis.MultiKeyPipelineBase

All Implemented Interfaces:

BasicRedisPipeline, BinaryRedisPipeline, BinaryScriptingCommandsPipeline, ClusterPipeline, MultiKeyBinaryRedisPipeline, MultiKeyCommandsPipeline, RedisPipeline, ScriptingCommandsPipeline

Direct Known Subclasses:

Pipeline, Transaction
```
public abstract class MultiKeyPipelineBase
extends PipelineBase
implements MultiKeyBinaryRedisPipeline, MultiKeyCommandsPipeline, ClusterPipeline, BinaryScriptingCommandsPipeline, ScriptingCommandsPipeline, BasicRedisPipeline
```

Field Summary

Fields
Modifier and Type Field and Description

protected Client client

Fields
Modifier and Type	Field and Description
`protected Client`	`client`

Constructor Summary

Constructors
Constructor and Description

MultiKeyPipelineBase()

Constructors
Constructor and Description
`MultiKeyPipelineBase()`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`Response<String>`	`bgrewriteaof()`
`Response<String>`	`bgsave()`
`Response<Long>`	`bitop(BitOP op, byte[] destKey, byte[]... srcKeys)`
`Response<Long>`	`bitop(BitOP op, String destKey, String... srcKeys)`
`Response<byte[]>`	`blmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to, double timeout)`
`Response<String>`	`blmove(String srcKey, String dstKey, ListDirection from, ListDirection to, double timeout)`
`Response<List<byte[]>>`	`blpop(byte[]... args)`
`Response<List<byte[]>>`	`blpop(double timeout, byte[]... keys)`
`Response<KeyedListElement>`	`blpop(double timeout, String... keys)`
`Response<List<String>>`	`blpop(int timeout, byte[]... keys)` Deprecated.
`Response<List<String>>`	`blpop(int timeout, String... keys)`
`Response<List<String>>`	`blpop(String... args)`
`Response<Map<String,String>>`	`blpopMap(int timeout, String... keys)` Deprecated. Use `blpop(double, java.lang.String...)` or `blpop(int, java.lang.String...)`.
`Response<List<byte[]>>`	`brpop(byte[]... args)`
`Response<List<byte[]>>`	`brpop(double timeout, byte[]... keys)`
`Response<KeyedListElement>`	`brpop(double timeout, String... keys)`
`Response<List<String>>`	`brpop(int timeout, byte[]... keys)` Deprecated.
`Response<List<String>>`	`brpop(int timeout, String... keys)`
`Response<List<String>>`	`brpop(String... args)`
`Response<byte[]>`	`brpoplpush(byte[] source, byte[] destination, int timeout)`
`Response<String>`	`brpoplpush(String source, String destination, int timeout)`
`Response<Map<String,String>>`	`brpopMap(int timeout, String... keys)` Deprecated. Use `brpop(double, java.lang.String...)` or `brpop(int, java.lang.String...)`.
`Response<List<byte[]>>`	`bzpopmax(double timeout, byte[]... keys)`
`Response<KeyedZSetElement>`	`bzpopmax(double timeout, String... keys)`
`Response<List<byte[]>>`	`bzpopmin(double timeout, byte[]... keys)`
`Response<KeyedZSetElement>`	`bzpopmin(double timeout, String... keys)`
`Response<String>`	`clusterAddSlots(int... slots)`
`Response<String>`	`clusterDelSlots(int... slots)`
`Response<List<String>>`	`clusterGetKeysInSlot(int slot, int count)`
`Response<String>`	`clusterInfo()`
`Response<String>`	`clusterMeet(String ip, int port)`
`Response<String>`	`clusterNodes()`
`Response<String>`	`clusterSetSlotImporting(int slot, String nodeId)`
`Response<String>`	`clusterSetSlotMigrating(int slot, String nodeId)`
`Response<String>`	`clusterSetSlotNode(int slot, String nodeId)`
`Response<List<String>>`	`configGet(String pattern)`
`Response<String>`	`configResetStat()`
`Response<String>`	`configSet(String parameter, String value)`
`Response<Boolean>`	`copy(byte[] srcKey, byte[] dstKey, boolean replace)`
`Response<Boolean>`	`copy(byte[] srcKey, byte[] dstKey, int db, boolean replace)`
`Response<Boolean>`	`copy(String srcKey, String dstKey, boolean replace)`
`Response<Boolean>`	`copy(String srcKey, String dstKey, int db, boolean replace)`
`Response<Long>`	`dbSize()`
`Response<Long>`	`del(byte[]... keys)`
`Response<Long>`	`del(String... keys)`
`Response<Object>`	`eval(byte[] script)`
`Response<Object>`	`eval(byte[] script, byte[] keyCount, byte[]... params)`
`Response<Object>`	`eval(byte[] script, int keyCount, byte[]... params)`
`Response<Object>`	`eval(byte[] script, List<byte[]> keys, List<byte[]> args)`
`Response<Object>`	`eval(String script)`
`Response<Object>`	`eval(String script, int keyCount, String... params)`
`Response<Object>`	`eval(String script, List<String> keys, List<String> args)`
`Response<Object>`	`evalsha(byte[] sha1)`
`Response<Object>`	`evalsha(byte[] sha1, int keyCount, byte[]... params)`
`Response<Object>`	`evalsha(byte[] sha1, List<byte[]> keys, List<byte[]> args)`
`Response<Object>`	`evalsha(String sha1)`
`Response<Object>`	`evalsha(String sha1, int keyCount, String... params)`
`Response<Object>`	`evalsha(String sha1, List<String> keys, List<String> args)`
`Response<Long>`	`exists(byte[]... keys)`
`Response<Long>`	`exists(String... keys)`
`Response<String>`	`flushAll()`
`Response<String>`	`flushAll(FlushMode flushMode)`
`Response<String>`	`flushDB()`
`Response<String>`	`flushDB(FlushMode flushMode)`
`Response<Long>`	`georadiusByMemberStore(byte[] key, byte[] member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)`
`Response<Long>`	`georadiusByMemberStore(String key, String member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)`
`Response<Long>`	`georadiusStore(byte[] key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)`
`Response<Long>`	`georadiusStore(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)`
`Response<String>`	`info()`
`Response<String>`	`info(String section)`
`Response<Set<byte[]>>`	`keys(byte[] pattern)`
`Response<Set<String>>`	`keys(String pattern)`
`Response<Long>`	`lastsave()`
`Response<byte[]>`	`lmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to)`
`Response<String>`	`lmove(String srcKey, String dstKey, ListDirection from, ListDirection to)`
`Response<List<byte[]>>`	`mget(byte[]... keys)`
`Response<List<String>>`	`mget(String... keys)`
`Response<String>`	`migrate(String host, int port, int destinationDB, int timeout, MigrateParams params, byte[]... keys)`
`Response<String>`	`migrate(String host, int port, int destinationDB, int timeout, MigrateParams params, String... keys)`
`Response<List<Module>>`	`moduleList()`
`Response<String>`	`moduleLoad(String path)`
`Response<String>`	`moduleUnload(String name)`
`Response<String>`	`mset(byte[]... keysvalues)`
`Response<String>`	`mset(String... keysvalues)`
`Response<Long>`	`msetnx(byte[]... keysvalues)`
`Response<Long>`	`msetnx(String... keysvalues)`
`Response<Long>`	`pfcount(byte[]... keys)`
`Response<Long>`	`pfcount(String... keys)`
`Response<String>`	`pfmerge(byte[] destkey, byte[]... sourcekeys)`
`Response<String>`	`pfmerge(String destkey, String... sourcekeys)`
`Response<String>`	`ping()`
`Response<Long>`	`publish(byte[] channel, byte[] message)`
`Response<Long>`	`publish(String channel, String message)`
`Response<String>`	`randomKey()`
`Response<byte[]>`	`randomKeyBinary()`
`Response<String>`	`rename(byte[] oldkey, byte[] newkey)`
`Response<String>`	`rename(String oldkey, String newkey)`
`Response<Long>`	`renamenx(byte[] oldkey, byte[] newkey)`
`Response<Long>`	`renamenx(String oldkey, String newkey)`
`Response<byte[]>`	`rpoplpush(byte[] srckey, byte[] dstkey)`
`Response<String>`	`rpoplpush(String srckey, String dstkey)`
`Response<String>`	`save()`
`Response<Set<byte[]>>`	`sdiff(byte[]... keys)`
`Response<Set<String>>`	`sdiff(String... keys)`
`Response<Long>`	`sdiffstore(byte[] dstkey, byte[]... keys)`
`Response<Long>`	`sdiffstore(String dstkey, String... keys)`
`Response<String>`	`select(int index)`
`Response<Object>`	`sendCommand(ProtocolCommand cmd, byte[]... args)`
`Response<Object>`	`sendCommand(ProtocolCommand cmd, String... args)`
`Response<String>`	`shutdown()`
`Response<Set<byte[]>>`	`sinter(byte[]... keys)`
`Response<Set<String>>`	`sinter(String... keys)`
`Response<Long>`	`sinterstore(byte[] dstkey, byte[]... keys)`
`Response<Long>`	`sinterstore(String dstkey, String... keys)`
`Response<Long>`	`smove(byte[] srckey, byte[] dstkey, byte[] member)`
`Response<Long>`	`smove(String srckey, String dstkey, String member)`
`Response<Long>`	`sort(byte[] key, byte[] dstkey)`
`Response<Long>`	`sort(byte[] key, SortingParams sortingParameters, byte[] dstkey)`
`Response<Long>`	`sort(String key, SortingParams sortingParameters, String dstkey)`
`Response<Long>`	`sort(String key, String dstkey)`
`Response<Set<byte[]>>`	`sunion(byte[]... keys)`
`Response<Set<String>>`	`sunion(String... keys)`
`Response<Long>`	`sunionstore(byte[] dstkey, byte[]... keys)`
`Response<Long>`	`sunionstore(String dstkey, String... keys)`
`Response<String>`	`swapDB(int index1, int index2)`
`Response<List<String>>`	`time()`
`Response<Long>`	`touch(byte[]... keys)`
`Response<Long>`	`touch(String... keys)`
`Response<Long>`	`unlink(byte[]... keys)`
`Response<Long>`	`unlink(String... keys)`
`Response<String>`	`unwatch()`
`Response<String>`	`watch(byte[]... keys)`
`Response<String>`	`watch(String... keys)`
`Response<List<Map.Entry<String,List<StreamEntry>>>>`	`xread(int count, long block, Map.Entry<String,StreamEntryID>... streams)`
`Response<List<byte[]>>`	`xread(int count, long block, Map<byte[],byte[]> streams)`
`Response<List<byte[]>>`	`xread(XReadParams xReadParams, Map.Entry<byte[],byte[]>... streams)`
`Response<List<Map.Entry<String,List<StreamEntry>>>>`	`xread(XReadParams xReadParams, Map<String,StreamEntryID> streams)`
`Response<List<byte[]>>`	`xreadGroup(byte[] groupname, byte[] consumer, int count, long block, boolean noAck, Map<byte[],byte[]> streams)`
`Response<List<byte[]>>`	`xreadGroup(byte[] groupname, byte[] consumer, XReadGroupParams xReadGroupParams, Map.Entry<byte[],byte[]>... streams)`
`Response<List<Map.Entry<String,List<StreamEntry>>>>`	`xreadGroup(String groupname, String consumer, int count, long block, boolean noAck, Map.Entry<String,StreamEntryID>... streams)`
`Response<List<Map.Entry<String,List<StreamEntry>>>>`	`xreadGroup(String groupname, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams)`
`Response<Set<byte[]>>`	`zdiff(byte[]... keys)`
`Response<Set<String>>`	`zdiff(String... keys)`
`Response<Long>`	`zdiffStore(byte[] dstkey, byte[]... keys)`
`Response<Long>`	`zdiffStore(String dstkey, String... keys)`
`Response<Set<Tuple>>`	`zdiffWithScores(byte[]... keys)`
`Response<Set<Tuple>>`	`zdiffWithScores(String... keys)`
`Response<Set<byte[]>>`	`zinter(ZParams params, byte[]... keys)`
`Response<Set<String>>`	`zinter(ZParams params, String... keys)`
`Response<Long>`	`zinterstore(byte[] dstkey, byte[]... sets)`
`Response<Long>`	`zinterstore(byte[] dstkey, ZParams params, byte[]... sets)`
`Response<Long>`	`zinterstore(String dstkey, String... sets)`
`Response<Long>`	`zinterstore(String dstkey, ZParams params, String... sets)`
`Response<Set<Tuple>>`	`zinterWithScores(ZParams params, byte[]... keys)`
`Response<Set<Tuple>>`	`zinterWithScores(ZParams params, String... keys)`
`Response<Set<byte[]>>`	`zunion(ZParams params, byte[]... keys)`
`Response<Set<String>>`	`zunion(ZParams params, String... keys)`
`Response<Long>`	`zunionstore(byte[] dstkey, byte[]... sets)`
`Response<Long>`	`zunionstore(byte[] dstkey, ZParams params, byte[]... sets)`
`Response<Long>`	`zunionstore(String dstkey, String... sets)`
`Response<Long>`	`zunionstore(String dstkey, ZParams params, String... sets)`
`Response<Set<Tuple>>`	`zunionWithScores(ZParams params, byte[]... keys)`
`Response<Set<Tuple>>`	`zunionWithScores(ZParams params, String... keys)`

Methods inherited from class redis.clients.jedis.PipelineBase
append, append, bitcount, bitcount, bitcount, bitcount, bitfield, bitfield, bitfieldReadonly, bitfieldReadonly, bitpos, bitpos, bitpos, bitpos, blpop, blpop, brpop, brpop, decr, decr, decrBy, decrBy, del, del, dump, dump, echo, echo, exists, exists, expire, expire, expireAt, expireAt, geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geodist, geodist, geodist, geohash, geohash, geopos, geopos, georadius, georadius, georadius, georadius, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, get, get, getbit, getbit, getClient, getClient, getDel, getDel, getEx, getEx, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hget, hget, hgetAll, hgetAll, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hrandfield, hrandfield, hrandfield, hrandfield, hrandfieldWithValues, hrandfieldWithValues, hset, hset, hset, hset, hsetnx, hsetnx, hstrlen, hstrlen, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, lindex, lindex, linsert, linsert, llen, llen, lpop, lpop, lpop, lpop, lpos, lpos, lpos, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, migrate, migrate, move, move, objectEncoding, objectEncoding, objectFreq, objectFreq, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpireAt, pexpireAt, pfadd, pfadd, pfcount, pfcount, psetex, psetex, pttl, pttl, restore, restore, restore, restore, restoreReplace, restoreReplace, rpop, rpop, rpop, rpop, rpush, rpush, rpushx, rpushx, sadd, sadd, scard, scard, sendCommand, sendCommand, set, set, set, set, setbit, setbit, setex, setex, setnx, setnx, setrange, setrange, sismember, sismember, smembers, smembers, smismember, smismember, sort, sort, sort, sort, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, strlen, strlen, substr, substr, touch, touch, ttl, ttl, type, type, unlink, unlink, xack, xack, xadd, xadd, xadd, xadd, xadd, xadd, xclaim, xclaim, xclaim, xclaim, xclaimJustId, xclaimJustId, xdel, xdel, xgroupCreate, xgroupCreate, xgroupDelConsumer, xgroupDelConsumer, xgroupDestroy, xgroupDestroy, xgroupSetID, xgroupSetID, xlen, xlen, xpending, xpending, xpending, xpending, xpending, xpending, xpendingBinary, xrange, xrange, xrange, xrange, xrevrange, xrevrange, xrevrange, xrevrange, xtrim, xtrim, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcard, zcount, zcount, zcount, zcount, zincrby, zincrby, zincrby, zincrby, zlexcount, zlexcount, zmscore, zmscore, zpopmax, zpopmax, zpopmax, zpopmax, zpopmin, zpopmin, zpopmin, zpopmin, zrandmember, zrandmember, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, zrem, zrem, zremrangeByLex, zremrangeByLex, zremrangeByRank, zremrangeByRank, zremrangeByScore, zremrangeByScore, zremrangeByScore, zremrangeByScore, zrevrange, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrank, zscore, zscore

Methods inherited from class redis.clients.jedis.Queable
clean, generateResponse, getPipelinedResponseLength, getResponse, hasPipelinedResponse

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface redis.clients.jedis.commands.BasicRedisPipeline
migrate

Methods inherited from interface redis.clients.jedis.commands.BinaryRedisPipeline
expire, restore, restoreReplace, setex

Methods inherited from interface redis.clients.jedis.commands.RedisPipeline
expire, restore, restoreReplace, setex

Field Detail
- client
```
protected Client client
```

Constructor Detail
- MultiKeyPipelineBase
```
public MultiKeyPipelineBase()
```

Method Detail

copy

public Response<Boolean> copy(byte[] srcKey,
                              byte[] dstKey,
                              int db,
                              boolean replace)

Specified by:: copy in interface MultiKeyBinaryRedisPipeline

copy

public Response<Boolean> copy(byte[] srcKey,
                              byte[] dstKey,
                              boolean replace)

Specified by:: copy in interface MultiKeyBinaryRedisPipeline

copy

public Response<Boolean> copy(String srcKey,
                              String dstKey,
                              int db,
                              boolean replace)

Specified by:: copy in interface MultiKeyCommandsPipeline

copy

public Response<Boolean> copy(String srcKey,
                              String dstKey,
                              boolean replace)

Specified by:: copy in interface MultiKeyCommandsPipeline

lmove

public Response<String> lmove(String srcKey,
                              String dstKey,
                              ListDirection from,
                              ListDirection to)

Specified by:: lmove in interface MultiKeyCommandsPipeline

lmove

public Response<byte[]> lmove(byte[] srcKey,
                              byte[] dstKey,
                              ListDirection from,
                              ListDirection to)

Specified by:: lmove in interface MultiKeyBinaryRedisPipeline

blmove

public Response<String> blmove(String srcKey,
                               String dstKey,
                               ListDirection from,
                               ListDirection to,
                               double timeout)

Specified by:: blmove in interface MultiKeyCommandsPipeline

blmove

public Response<byte[]> blmove(byte[] srcKey,
                               byte[] dstKey,
                               ListDirection from,
                               ListDirection to,
                               double timeout)

Specified by:: blmove in interface MultiKeyBinaryRedisPipeline

blpop
```
public Response<List<String>> blpop(String... args)
```
Specified by:

blpop in interface MultiKeyCommandsPipeline

blpop
```
public Response<List<byte[]>> blpop(byte[]... args)
```
Specified by:

blpop in interface MultiKeyBinaryRedisPipeline

blpop

public Response<List<String>> blpop(int timeout,
                                    String... keys)

Specified by:: blpop in interface MultiKeyCommandsPipeline

blpopMap

@Deprecated
public Response<Map<String,String>> blpopMap(int timeout,
                                                         String... keys)

Deprecated. Use blpop(double, java.lang.String...) or blpop(int, java.lang.String...).

blpop

@Deprecated
public Response<List<String>> blpop(int timeout,
                                                byte[]... keys)

Deprecated.

blpop

public Response<KeyedListElement> blpop(double timeout,
                                        String... keys)

Specified by:: blpop in interface MultiKeyCommandsPipeline

blpop

public Response<List<byte[]>> blpop(double timeout,
                                    byte[]... keys)

Specified by:: blpop in interface MultiKeyBinaryRedisPipeline

brpop
```
public Response<List<String>> brpop(String... args)
```
Specified by:

brpop in interface MultiKeyCommandsPipeline

brpop
```
public Response<List<byte[]>> brpop(byte[]... args)
```
Specified by:

brpop in interface MultiKeyBinaryRedisPipeline

brpop

public Response<List<String>> brpop(int timeout,
                                    String... keys)

Specified by:: brpop in interface MultiKeyCommandsPipeline

brpopMap

@Deprecated
public Response<Map<String,String>> brpopMap(int timeout,
                                                         String... keys)

Deprecated. Use brpop(double, java.lang.String...) or brpop(int, java.lang.String...).

brpop

@Deprecated
public Response<List<String>> brpop(int timeout,
                                                byte[]... keys)

Deprecated.

brpop

public Response<KeyedListElement> brpop(double timeout,
                                        String... keys)

Specified by:: brpop in interface MultiKeyCommandsPipeline

brpop

public Response<List<byte[]>> brpop(double timeout,
                                    byte[]... keys)

Specified by:: brpop in interface MultiKeyBinaryRedisPipeline

bzpopmax

public Response<KeyedZSetElement> bzpopmax(double timeout,
                                           String... keys)

Specified by:: bzpopmax in interface MultiKeyCommandsPipeline

bzpopmax

public Response<List<byte[]>> bzpopmax(double timeout,
                                       byte[]... keys)

Specified by:: bzpopmax in interface MultiKeyBinaryRedisPipeline

bzpopmin

public Response<KeyedZSetElement> bzpopmin(double timeout,
                                           String... keys)

Specified by:: bzpopmin in interface MultiKeyCommandsPipeline

bzpopmin

public Response<List<byte[]>> bzpopmin(double timeout,
                                       byte[]... keys)

Specified by:: bzpopmin in interface MultiKeyBinaryRedisPipeline

del
```
public Response<Long> del(String... keys)
```
Specified by:

del in interface MultiKeyCommandsPipeline

del
```
public Response<Long> del(byte[]... keys)
```
Specified by:

del in interface MultiKeyBinaryRedisPipeline

unlink
```
public Response<Long> unlink(String... keys)
```
Specified by:

unlink in interface MultiKeyCommandsPipeline

unlink
```
public Response<Long> unlink(byte[]... keys)
```
Specified by:

unlink in interface MultiKeyBinaryRedisPipeline

exists
```
public Response<Long> exists(String... keys)
```
Specified by:

exists in interface MultiKeyCommandsPipeline

exists
```
public Response<Long> exists(byte[]... keys)
```
Specified by:

exists in interface MultiKeyBinaryRedisPipeline

keys
```
public Response<Set<String>> keys(String pattern)
```
Specified by:

keys in interface MultiKeyCommandsPipeline

keys
```
public Response<Set<byte[]>> keys(byte[] pattern)
```
Specified by:

keys in interface MultiKeyBinaryRedisPipeline

mget
```
public Response<List<String>> mget(String... keys)
```
Specified by:

mget in interface MultiKeyCommandsPipeline

mget
```
public Response<List<byte[]>> mget(byte[]... keys)
```
Specified by:

mget in interface MultiKeyBinaryRedisPipeline

mset
```
public Response<String> mset(String... keysvalues)
```
Specified by:

mset in interface MultiKeyCommandsPipeline

mset
```
public Response<String> mset(byte[]... keysvalues)
```
Specified by:

mset in interface MultiKeyBinaryRedisPipeline

msetnx
```
public Response<Long> msetnx(String... keysvalues)
```
Specified by:

msetnx in interface MultiKeyCommandsPipeline

msetnx
```
public Response<Long> msetnx(byte[]... keysvalues)
```
Specified by:

msetnx in interface MultiKeyBinaryRedisPipeline

rename

public Response<String> rename(String oldkey,
                               String newkey)

Specified by:: rename in interface MultiKeyCommandsPipeline

rename

public Response<String> rename(byte[] oldkey,
                               byte[] newkey)

Specified by:: rename in interface MultiKeyBinaryRedisPipeline

renamenx

public Response<Long> renamenx(String oldkey,
                               String newkey)

Specified by:: renamenx in interface MultiKeyCommandsPipeline

renamenx

public Response<Long> renamenx(byte[] oldkey,
                               byte[] newkey)

Specified by:: renamenx in interface MultiKeyBinaryRedisPipeline

rpoplpush

public Response<String> rpoplpush(String srckey,
                                  String dstkey)

Specified by:: rpoplpush in interface MultiKeyCommandsPipeline

rpoplpush

public Response<byte[]> rpoplpush(byte[] srckey,
                                  byte[] dstkey)

Specified by:: rpoplpush in interface MultiKeyBinaryRedisPipeline

sdiff
```
public Response<Set<String>> sdiff(String... keys)
```
Specified by:

sdiff in interface MultiKeyCommandsPipeline

sdiff
```
public Response<Set<byte[]>> sdiff(byte[]... keys)
```
Specified by:

sdiff in interface MultiKeyBinaryRedisPipeline

sdiffstore

public Response<Long> sdiffstore(String dstkey,
                                 String... keys)

Specified by:: sdiffstore in interface MultiKeyCommandsPipeline

sdiffstore

public Response<Long> sdiffstore(byte[] dstkey,
                                 byte[]... keys)

Specified by:: sdiffstore in interface MultiKeyBinaryRedisPipeline

sinter
```
public Response<Set<String>> sinter(String... keys)
```
Specified by:

sinter in interface MultiKeyCommandsPipeline

sinter
```
public Response<Set<byte[]>> sinter(byte[]... keys)
```
Specified by:

sinter in interface MultiKeyBinaryRedisPipeline

sinterstore

public Response<Long> sinterstore(String dstkey,
                                  String... keys)

Specified by:: sinterstore in interface MultiKeyCommandsPipeline

sinterstore

public Response<Long> sinterstore(byte[] dstkey,
                                  byte[]... keys)

Specified by:: sinterstore in interface MultiKeyBinaryRedisPipeline

smove

public Response<Long> smove(String srckey,
                            String dstkey,
                            String member)

Specified by:: smove in interface MultiKeyCommandsPipeline

smove

public Response<Long> smove(byte[] srckey,
                            byte[] dstkey,
                            byte[] member)

Specified by:: smove in interface MultiKeyBinaryRedisPipeline

sort

public Response<Long> sort(String key,
                           SortingParams sortingParameters,
                           String dstkey)

Specified by:: sort in interface MultiKeyCommandsPipeline

sort

public Response<Long> sort(byte[] key,
                           SortingParams sortingParameters,
                           byte[] dstkey)

Specified by:: sort in interface MultiKeyBinaryRedisPipeline

sort

public Response<Long> sort(String key,
                           String dstkey)

Specified by:: sort in interface MultiKeyCommandsPipeline

sort

public Response<Long> sort(byte[] key,
                           byte[] dstkey)

Specified by:: sort in interface MultiKeyBinaryRedisPipeline

sunion
```
public Response<Set<String>> sunion(String... keys)
```
Specified by:

sunion in interface MultiKeyCommandsPipeline

sunion
```
public Response<Set<byte[]>> sunion(byte[]... keys)
```
Specified by:

sunion in interface MultiKeyBinaryRedisPipeline

sunionstore

public Response<Long> sunionstore(String dstkey,
                                  String... keys)

Specified by:: sunionstore in interface MultiKeyCommandsPipeline

sunionstore

public Response<Long> sunionstore(byte[] dstkey,
                                  byte[]... keys)

Specified by:: sunionstore in interface MultiKeyBinaryRedisPipeline

watch
```
public Response<String> watch(String... keys)
```
Specified by:

watch in interface MultiKeyCommandsPipeline

watch
```
public Response<String> watch(byte[]... keys)
```
Specified by:

watch in interface MultiKeyBinaryRedisPipeline

unwatch
```
public Response<String> unwatch()
```
Specified by:

unwatch in interface MultiKeyBinaryRedisPipeline

Specified by:

unwatch in interface MultiKeyCommandsPipeline

zdiff
```
public Response<Set<byte[]>> zdiff(byte[]... keys)
```
Specified by:

zdiff in interface MultiKeyBinaryRedisPipeline

zdiffWithScores
```
public Response<Set<Tuple>> zdiffWithScores(byte[]... keys)
```
Specified by:

zdiffWithScores in interface MultiKeyBinaryRedisPipeline

zdiff
```
public Response<Set<String>> zdiff(String... keys)
```
Specified by:

zdiff in interface MultiKeyCommandsPipeline

zdiffWithScores
```
public Response<Set<Tuple>> zdiffWithScores(String... keys)
```
Specified by:

zdiffWithScores in interface MultiKeyCommandsPipeline

zdiffStore

public Response<Long> zdiffStore(byte[] dstkey,
                                 byte[]... keys)

Specified by:: zdiffStore in interface MultiKeyBinaryRedisPipeline

zdiffStore

public Response<Long> zdiffStore(String dstkey,
                                 String... keys)

Specified by:: zdiffStore in interface MultiKeyCommandsPipeline

zinter

public Response<Set<byte[]>> zinter(ZParams params,
                                    byte[]... keys)

Specified by:: zinter in interface MultiKeyBinaryRedisPipeline

zinterWithScores

public Response<Set<Tuple>> zinterWithScores(ZParams params,
                                             byte[]... keys)

Specified by:: zinterWithScores in interface MultiKeyBinaryRedisPipeline

zinter

public Response<Set<String>> zinter(ZParams params,
                                    String... keys)

Specified by:: zinter in interface MultiKeyCommandsPipeline

zinterWithScores

public Response<Set<Tuple>> zinterWithScores(ZParams params,
                                             String... keys)

Specified by:: zinterWithScores in interface MultiKeyCommandsPipeline

zinterstore

public Response<Long> zinterstore(String dstkey,
                                  String... sets)

Specified by:: zinterstore in interface MultiKeyCommandsPipeline

zinterstore

public Response<Long> zinterstore(byte[] dstkey,
                                  byte[]... sets)

Specified by:: zinterstore in interface MultiKeyBinaryRedisPipeline

zinterstore

public Response<Long> zinterstore(String dstkey,
                                  ZParams params,
                                  String... sets)

Specified by:: zinterstore in interface MultiKeyCommandsPipeline

zinterstore

public Response<Long> zinterstore(byte[] dstkey,
                                  ZParams params,
                                  byte[]... sets)

Specified by:: zinterstore in interface MultiKeyBinaryRedisPipeline

zunion

public Response<Set<byte[]>> zunion(ZParams params,
                                    byte[]... keys)

Specified by:: zunion in interface MultiKeyBinaryRedisPipeline

zunionWithScores

public Response<Set<Tuple>> zunionWithScores(ZParams params,
                                             byte[]... keys)

Specified by:: zunionWithScores in interface MultiKeyBinaryRedisPipeline

zunion

public Response<Set<String>> zunion(ZParams params,
                                    String... keys)

Specified by:: zunion in interface MultiKeyCommandsPipeline

zunionWithScores

public Response<Set<Tuple>> zunionWithScores(ZParams params,
                                             String... keys)

Specified by:: zunionWithScores in interface MultiKeyCommandsPipeline

zunionstore

public Response<Long> zunionstore(String dstkey,
                                  String... sets)

Specified by:: zunionstore in interface MultiKeyCommandsPipeline

zunionstore

public Response<Long> zunionstore(byte[] dstkey,
                                  byte[]... sets)

Specified by:: zunionstore in interface MultiKeyBinaryRedisPipeline

zunionstore

public Response<Long> zunionstore(String dstkey,
                                  ZParams params,
                                  String... sets)

Specified by:: zunionstore in interface MultiKeyCommandsPipeline

zunionstore

public Response<Long> zunionstore(byte[] dstkey,
                                  ZParams params,
                                  byte[]... sets)

Specified by:: zunionstore in interface MultiKeyBinaryRedisPipeline

bgrewriteaof
```
public Response<String> bgrewriteaof()
```
Specified by:

bgrewriteaof in interface BasicRedisPipeline

bgsave
```
public Response<String> bgsave()
```
Specified by:

bgsave in interface BasicRedisPipeline

configGet

public Response<List<String>> configGet(String pattern)

Specified by:: configGet in interface BasicRedisPipeline

configSet

public Response<String> configSet(String parameter,
                                  String value)

Specified by:: configSet in interface BasicRedisPipeline

brpoplpush

public Response<String> brpoplpush(String source,
                                   String destination,
                                   int timeout)

Specified by:: brpoplpush in interface MultiKeyCommandsPipeline

brpoplpush

public Response<byte[]> brpoplpush(byte[] source,
                                   byte[] destination,
                                   int timeout)

Specified by:: brpoplpush in interface MultiKeyBinaryRedisPipeline

configResetStat
```
public Response<String> configResetStat()
```
Specified by:

configResetStat in interface BasicRedisPipeline

save
```
public Response<String> save()
```
Specified by:

save in interface BasicRedisPipeline

lastsave
```
public Response<Long> lastsave()
```
Specified by:

lastsave in interface BasicRedisPipeline

publish

public Response<Long> publish(String channel,
                              String message)

Specified by:: publish in interface MultiKeyCommandsPipeline

publish

public Response<Long> publish(byte[] channel,
                              byte[] message)

Specified by:: publish in interface MultiKeyBinaryRedisPipeline

randomKey
```
public Response<String> randomKey()
```
Specified by:

randomKey in interface MultiKeyCommandsPipeline

randomKeyBinary
```
public Response<byte[]> randomKeyBinary()
```
Specified by:

randomKeyBinary in interface MultiKeyBinaryRedisPipeline

flushDB
```
public Response<String> flushDB()
```
Specified by:

flushDB in interface BasicRedisPipeline

flushAll
```
public Response<String> flushAll()
```
Specified by:

flushAll in interface BasicRedisPipeline

flushDB

public Response<String> flushDB(FlushMode flushMode)

Specified by:: flushDB in interface BasicRedisPipeline

flushAll

public Response<String> flushAll(FlushMode flushMode)

Specified by:: flushAll in interface BasicRedisPipeline

info
```
public Response<String> info()
```
Specified by:

info in interface BasicRedisPipeline

info

public Response<String> info(String section)

dbSize
```
public Response<Long> dbSize()
```
Specified by:

dbSize in interface BasicRedisPipeline

shutdown
```
public Response<String> shutdown()
```
Specified by:

shutdown in interface BasicRedisPipeline

ping
```
public Response<String> ping()
```
Specified by:

ping in interface BasicRedisPipeline

select
```
public Response<String> select(int index)
```
Specified by:

select in interface BasicRedisPipeline

swapDB

public Response<String> swapDB(int index1,
                               int index2)

Specified by:: swapDB in interface BasicRedisPipeline

bitop

public Response<Long> bitop(BitOP op,
                            byte[] destKey,
                            byte[]... srcKeys)

Specified by:: bitop in interface MultiKeyBinaryRedisPipeline

bitop

public Response<Long> bitop(BitOP op,
                            String destKey,
                            String... srcKeys)

Specified by:: bitop in interface MultiKeyCommandsPipeline

clusterNodes
```
public Response<String> clusterNodes()
```
Specified by:

clusterNodes in interface ClusterPipeline

clusterMeet

public Response<String> clusterMeet(String ip,
                                    int port)

Specified by:: clusterMeet in interface ClusterPipeline

clusterAddSlots
```
public Response<String> clusterAddSlots(int... slots)
```
Specified by:

clusterAddSlots in interface ClusterPipeline

clusterDelSlots
```
public Response<String> clusterDelSlots(int... slots)
```
Specified by:

clusterDelSlots in interface ClusterPipeline

clusterInfo
```
public Response<String> clusterInfo()
```
Specified by:

clusterInfo in interface ClusterPipeline

clusterGetKeysInSlot

public Response<List<String>> clusterGetKeysInSlot(int slot,
                                                   int count)

Specified by:: clusterGetKeysInSlot in interface ClusterPipeline

clusterSetSlotNode

public Response<String> clusterSetSlotNode(int slot,
                                           String nodeId)

Specified by:: clusterSetSlotNode in interface ClusterPipeline

clusterSetSlotMigrating

public Response<String> clusterSetSlotMigrating(int slot,
                                                String nodeId)

Specified by:: clusterSetSlotMigrating in interface ClusterPipeline

clusterSetSlotImporting

public Response<String> clusterSetSlotImporting(int slot,
                                                String nodeId)

Specified by:: clusterSetSlotImporting in interface ClusterPipeline

eval
```
public Response<Object> eval(String script)
```
Specified by:

eval in interface ScriptingCommandsPipeline

eval

public Response<Object> eval(String script,
                             List<String> keys,
                             List<String> args)

Specified by:: eval in interface ScriptingCommandsPipeline

eval

public Response<Object> eval(String script,
                             int keyCount,
                             String... params)

Specified by:: eval in interface ScriptingCommandsPipeline

evalsha
```
public Response<Object> evalsha(String sha1)
```
Specified by:

evalsha in interface ScriptingCommandsPipeline

evalsha

public Response<Object> evalsha(String sha1,
                                List<String> keys,
                                List<String> args)

Specified by:: evalsha in interface ScriptingCommandsPipeline

evalsha

public Response<Object> evalsha(String sha1,
                                int keyCount,
                                String... params)

Specified by:: evalsha in interface ScriptingCommandsPipeline

eval
```
public Response<Object> eval(byte[] script)
```
Specified by:

eval in interface BinaryScriptingCommandsPipeline

eval

public Response<Object> eval(byte[] script,
                             byte[] keyCount,
                             byte[]... params)

Specified by:: eval in interface BinaryScriptingCommandsPipeline

eval

public Response<Object> eval(byte[] script,
                             List<byte[]> keys,
                             List<byte[]> args)

Specified by:: eval in interface BinaryScriptingCommandsPipeline

eval

public Response<Object> eval(byte[] script,
                             int keyCount,
                             byte[]... params)

Specified by:: eval in interface BinaryScriptingCommandsPipeline

evalsha
```
public Response<Object> evalsha(byte[] sha1)
```
Specified by:

evalsha in interface BinaryScriptingCommandsPipeline

evalsha

public Response<Object> evalsha(byte[] sha1,
                                List<byte[]> keys,
                                List<byte[]> args)

Specified by:: evalsha in interface BinaryScriptingCommandsPipeline

evalsha

public Response<Object> evalsha(byte[] sha1,
                                int keyCount,
                                byte[]... params)

Specified by:: evalsha in interface BinaryScriptingCommandsPipeline

pfcount
```
public Response<Long> pfcount(String... keys)
```
Specified by:

pfcount in interface MultiKeyCommandsPipeline

pfcount
```
public Response<Long> pfcount(byte[]... keys)
```
Specified by:

pfcount in interface MultiKeyBinaryRedisPipeline

pfmerge

public Response<String> pfmerge(byte[] destkey,
                                byte[]... sourcekeys)

Specified by:: pfmerge in interface MultiKeyBinaryRedisPipeline

pfmerge

public Response<String> pfmerge(String destkey,
                                String... sourcekeys)

Specified by:: pfmerge in interface MultiKeyCommandsPipeline

time
```
public Response<List<String>> time()
```
Specified by:

time in interface BasicRedisPipeline

touch
```
public Response<Long> touch(String... keys)
```
Specified by:

touch in interface MultiKeyCommandsPipeline

touch
```
public Response<Long> touch(byte[]... keys)
```
Specified by:

touch in interface MultiKeyBinaryRedisPipeline

moduleUnload
```
public Response<String> moduleUnload(String name)
```
Specified by:

moduleUnload in interface BasicRedisPipeline

moduleList
```
public Response<List<Module>> moduleList()
```
Specified by:

moduleList in interface BasicRedisPipeline

moduleLoad
```
public Response<String> moduleLoad(String path)
```
Specified by:

moduleLoad in interface BasicRedisPipeline

migrate

public Response<String> migrate(String host,
                                int port,
                                int destinationDB,
                                int timeout,
                                MigrateParams params,
                                String... keys)

Specified by:: migrate in interface MultiKeyCommandsPipeline

migrate

public Response<String> migrate(String host,
                                int port,
                                int destinationDB,
                                int timeout,
                                MigrateParams params,
                                byte[]... keys)

Specified by:: migrate in interface MultiKeyBinaryRedisPipeline

sendCommand

public Response<Object> sendCommand(ProtocolCommand cmd,
                                    String... args)

sendCommand

public Response<Object> sendCommand(ProtocolCommand cmd,
                                    byte[]... args)

georadiusStore

public Response<Long> georadiusStore(String key,
                                     double longitude,
                                     double latitude,
                                     double radius,
                                     GeoUnit unit,
                                     GeoRadiusParam param,
                                     GeoRadiusStoreParam storeParam)

Specified by:: georadiusStore in interface MultiKeyCommandsPipeline

georadiusStore

public Response<Long> georadiusStore(byte[] key,
                                     double longitude,
                                     double latitude,
                                     double radius,
                                     GeoUnit unit,
                                     GeoRadiusParam param,
                                     GeoRadiusStoreParam storeParam)

Specified by:: georadiusStore in interface MultiKeyBinaryRedisPipeline

georadiusByMemberStore

public Response<Long> georadiusByMemberStore(byte[] key,
                                             byte[] member,
                                             double radius,
                                             GeoUnit unit,
                                             GeoRadiusParam param,
                                             GeoRadiusStoreParam storeParam)

Specified by:: georadiusByMemberStore in interface MultiKeyBinaryRedisPipeline

georadiusByMemberStore

public Response<Long> georadiusByMemberStore(String key,
                                             String member,
                                             double radius,
                                             GeoUnit unit,
                                             GeoRadiusParam param,
                                             GeoRadiusStoreParam storeParam)

Specified by:: georadiusByMemberStore in interface MultiKeyCommandsPipeline

xread

public Response<List<byte[]>> xread(int count,
                                    long block,
                                    Map<byte[],byte[]> streams)

Specified by:: xread in interface MultiKeyBinaryRedisPipeline

xread

public Response<List<byte[]>> xread(XReadParams xReadParams,
                                    Map.Entry<byte[],byte[]>... streams)

Specified by:: xread in interface MultiKeyBinaryRedisPipeline

xreadGroup

public Response<List<byte[]>> xreadGroup(byte[] groupname,
                                         byte[] consumer,
                                         int count,
                                         long block,
                                         boolean noAck,
                                         Map<byte[],byte[]> streams)

Specified by:: xreadGroup in interface MultiKeyBinaryRedisPipeline

xreadGroup

public Response<List<byte[]>> xreadGroup(byte[] groupname,
                                         byte[] consumer,
                                         XReadGroupParams xReadGroupParams,
                                         Map.Entry<byte[],byte[]>... streams)

Specified by:: xreadGroup in interface MultiKeyBinaryRedisPipeline

xread

public Response<List<Map.Entry<String,List<StreamEntry>>>> xread(int count,
                                                                 long block,
                                                                 Map.Entry<String,StreamEntryID>... streams)

Specified by:: xread in interface MultiKeyCommandsPipeline

xread

public Response<List<Map.Entry<String,List<StreamEntry>>>> xread(XReadParams xReadParams,
                                                                 Map<String,StreamEntryID> streams)

Specified by:: xread in interface MultiKeyCommandsPipeline

xreadGroup

public Response<List<Map.Entry<String,List<StreamEntry>>>> xreadGroup(String groupname,
                                                                      String consumer,
                                                                      int count,
                                                                      long block,
                                                                      boolean noAck,
                                                                      Map.Entry<String,StreamEntryID>... streams)

Specified by:: xreadGroup in interface MultiKeyCommandsPipeline

xreadGroup

public Response<List<Map.Entry<String,List<StreamEntry>>>> xreadGroup(String groupname,
                                                                      String consumer,
                                                                      XReadGroupParams xReadGroupParams,
                                                                      Map<String,StreamEntryID> streams)

Specified by:: xreadGroup in interface MultiKeyCommandsPipeline

Class MultiKeyPipelineBase

Field Summary

Constructor Summary

Method Summary

Methods inherited from class redis.clients.jedis.PipelineBase

Methods inherited from class redis.clients.jedis.Queable

Methods inherited from class java.lang.Object

Methods inherited from interface redis.clients.jedis.commands.BasicRedisPipeline

Methods inherited from interface redis.clients.jedis.commands.BinaryRedisPipeline

Methods inherited from interface redis.clients.jedis.commands.RedisPipeline

Field Detail

client

Constructor Detail

MultiKeyPipelineBase

Method Detail

copy

copy

copy

copy

lmove

lmove

blmove

blmove

blpop

blpop

blpop

blpopMap

blpop

blpop

blpop

brpop

brpop

brpop

brpopMap

brpop

brpop

brpop

bzpopmax

bzpopmax

bzpopmin

bzpopmin

del

del

unlink

unlink

exists

exists

keys

keys

mget

mget

mset

mset

msetnx

msetnx

rename

rename

renamenx

renamenx

rpoplpush

rpoplpush

sdiff

sdiff

sdiffstore

sdiffstore

sinter

sinter

sinterstore

sinterstore

smove

smove

sort

sort

sort

sort

sunion

sunion

sunionstore

sunionstore

watch