|
|
@ -156,18 +156,24 @@ public class Redisson implements RedissonClient {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public <V> List<RBucket<V>> getBuckets(String pattern) {
|
|
|
|
public <V> List<RBucket<V>> findBuckets(String pattern) {
|
|
|
|
Future<Collection<String>> r = commandExecutor.readAllAsync(RedisCommands.KEYS, pattern);
|
|
|
|
Future<Collection<String>> r = commandExecutor.readAllAsync(RedisCommands.KEYS, pattern);
|
|
|
|
Collection<String> keys = commandExecutor.get(r);
|
|
|
|
Collection<String> keys = commandExecutor.get(r);
|
|
|
|
List<RBucket<V>> buckets = new ArrayList<RBucket<V>>(keys.size());
|
|
|
|
List<RBucket<V>> buckets = new ArrayList<RBucket<V>>(keys.size());
|
|
|
|
for (Object key : keys) {
|
|
|
|
for (String key : keys) {
|
|
|
|
if(key != null) {
|
|
|
|
if(key == null) {
|
|
|
|
buckets.add(this.<V>getBucket(key.toString()));
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
buckets.add(this.<V>getBucket(key));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return buckets;
|
|
|
|
return buckets;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public <V> List<RBucket<V>> getBuckets(String pattern) {
|
|
|
|
|
|
|
|
return findBuckets(pattern);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public <V> RHyperLogLog<V> getHyperLogLog(String name) {
|
|
|
|
public <V> RHyperLogLog<V> getHyperLogLog(String name) {
|
|
|
|
return new RedissonHyperLogLog<V>(commandExecutor, name);
|
|
|
|
return new RedissonHyperLogLog<V>(commandExecutor, name);
|
|
|
|