redis.clients.jedis

Class ShardedJedisPipeline

java.lang.Object

redis.clients.jedis.Queable

redis.clients.jedis.PipelineBase

redis.clients.jedis.ShardedJedisPipeline

All Implemented Interfaces:

BinaryRedisPipeline, RedisPipeline

public class ShardedJedisPipeline
extends PipelineBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ShardedJedisPipeline.FutureResult

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Queue<Client>	clients
private BinaryShardedJedis	jedis
private java.util.List<ShardedJedisPipeline.FutureResult>	results

Constructor Summary

Constructors

Constructor and Description
ShardedJedisPipeline()

Method Summary

Modifier and Type	Method and Description
void	execute() Deprecated.
protected Client	getClient(byte[] key)
protected Client	getClient(java.lang.String key)
java.util.List<java.lang.Object>	getResults()
void	setShardedJedis(BinaryShardedJedis jedis)
void	sync() Syncronize pipeline by reading all responses.
java.util.List<java.lang.Object>	syncAndReturnAll() Syncronize pipeline by reading all responses.

Methods inherited from class redis.clients.jedis.PipelineBase

append, append, bitcount, bitcount, bitcount, bitcount, bitpos, bitpos, bitpos, bitpos, blpop, blpop, brpop, brpop, decr, decr, decrBy, decrBy, del, del, dump, dump, echo, echo, eval, eval, eval, evalsha, evalsha, evalsha, exists, exists, expire, expire, expireAt, expireAt, get, get, getbit, getbit, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hget, hget, hgetAll, hgetAll, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hset, hset, hsetnx, hsetnx, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, lindex, lindex, linsert, linsert, llen, llen, lpop, lpop, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, migrate, migrate, move, move, objectEncoding, objectEncoding, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpire, pexpire, pexpireAt, pexpireAt, pfadd, pfadd, pfcount, pfcount, psetex, psetex, psetex, psetex, pttl, pttl, restore, restore, rpop, rpop, rpush, rpush, rpushx, rpushx, sadd, sadd, scard, scard, set, set, set, set, set, set, setbit, setbit, setex, setex, setnx, setnx, setrange, setrange, sismember, sismember, smembers, smembers, sort, sort, sort, sort, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, strlen, strlen, substr, substr, ttl, ttl, type, type, zadd, zadd, zadd, zcard, zcard, zcount, zcount, zcount, zcount, zincrby, zincrby, zlexcount, zlexcount, 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

Field Detail

jedis

private BinaryShardedJedis jedis

results

private java.util.List<ShardedJedisPipeline.FutureResult> results

clients

private java.util.Queue<Client> clients

Constructor Detail

ShardedJedisPipeline

public ShardedJedisPipeline()

Method Detail

setShardedJedis

public void setShardedJedis(BinaryShardedJedis jedis)

getResults

public java.util.List<java.lang.Object> getResults()

sync

public void sync()

Syncronize pipeline by reading all responses. This operation closes the pipeline. In order to get return values from pipelined commands, capture the different Response<?> of the commands you execute.

syncAndReturnAll

public java.util.List<java.lang.Object> syncAndReturnAll()

Syncronize pipeline by reading all responses. This operation closes the pipeline. Whenever possible try to avoid using this version and use ShardedJedisPipeline.sync() as it won't go through all the responses and generate the right response type (usually it is a waste of time).

Returns:

A list of all the responses in the order you executed them.

execute

@Deprecated
public void execute()

Deprecated.

This method will be removed in Jedis 3.0. Use the methods that return Response's and call sync().

getClient

protected Client getClient(java.lang.String key)

Specified by:

getClient in class PipelineBase

getClient

protected Client getClient(byte[] key)

Specified by:

getClient in class PipelineBase