Package org.redisson
Class RedissonSet<V>
- java.lang.Object
-
- org.redisson.RedissonObject
-
- org.redisson.RedissonSet<V>
-
- Type Parameters:
V- value
- All Implemented Interfaces:
Iterable<V>,Collection<V>,Set<V>,RCollectionAsync<V>,RExpirable,RExpirableAsync,RObject,RObjectAsync,RSet<V>,RSetAsync<V>,RSortable<Set<V>>,RSortableAsync<Set<V>>,ScanIterator
- Direct Known Subclasses:
RedissonTransactionalSet
public class RedissonSet<V> extends RedissonObject implements RSet<V>, ScanIterator
Distributed and concurrent implementation ofSet- Author:
- Nikita Koksharov
-
-
Field Summary
-
Fields inherited from class org.redisson.RedissonObject
codec, commandExecutor, name
-
-
Constructor Summary
Constructors Constructor Description RedissonSet(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)RedissonSet(CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadd(V e)booleanaddAll(Collection<? extends V> c)RFuture<Boolean>addAllAsync(Collection<? extends V> c)Adds all elements contained in the specified collectionRFuture<Boolean>addAsync(V e)Adds element into this collection.voidclear()booleanclearExpire()Clear an expire timeout or expire date for object.RFuture<Boolean>clearExpireAsync()Clear an expire timeout or expire date for object in async mode.protected RFuture<Boolean>clearExpireAsync(String... keys)booleancontains(Object o)booleancontainsAll(Collection<?> c)RFuture<Boolean>containsAllAsync(Collection<?> c)Returnstrueif this collection contains all of the elements in the specified collection.RFuture<Boolean>containsAsync(Object o)Returnstrueif this collection contains encoded state of the specified element.intdiff(String... names)Diff sets specified by name and write to current set.RFuture<Integer>diffAsync(String... names)Diff sets specified by name and write to current set.booleanexpire(long timeToLive, TimeUnit timeUnit)Set a timeout for object.booleanexpire(Instant instant)Set an expire date for object.RFuture<Boolean>expireAsync(long timeToLive, TimeUnit timeUnit)Set a timeout for object in async mode.protected RFuture<Boolean>expireAsync(long timeToLive, TimeUnit timeUnit, String... keys)RFuture<Boolean>expireAsync(Instant instant)Set an expire date for object.booleanexpireAt(long timestamp)UseRExpirable.expire(Instant)insteadbooleanexpireAt(Date timestamp)UseRExpirable.expire(Instant)insteadRFuture<Boolean>expireAtAsync(long timestamp)UseRExpirableAsync.expireAsync(Instant)insteadprotected RFuture<Boolean>expireAtAsync(long timestamp, String... keys)RFuture<Boolean>expireAtAsync(Date timestamp)UseRExpirableAsync.expireAsync(Instant)insteadRCountDownLatchgetCountDownLatch(V value)ReturnsRCountDownLatchinstance associated withvalueRLockgetFairLock(V value)ReturnsRLockinstance associated withvalueRLockgetLock(V value)Returns lock instance associated withvalueRPermitExpirableSemaphoregetPermitExpirableSemaphore(V value)ReturnsRPermitExpirableSemaphoreinstance associated withvalueRReadWriteLockgetReadWriteLock(V value)ReturnsRReadWriteLockinstance associated withvalueRSemaphoregetSemaphore(V value)ReturnsRSemaphoreinstance associated withvalueintintersection(String... names)Intersection sets specified by name and write to current set.RFuture<Integer>intersectionAsync(String... names)Intersection sets specified by name and write to current set.booleanisEmpty()Iterator<V>iterator()Iterator<V>iterator(int count)Returns elements iterator fetches elements in a batch.Iterator<V>iterator(String pattern)Returns elements iterator.Iterator<V>iterator(String pattern, int count)Returns elements iterator fetches elements in a batch.<KOut,VOut>
RCollectionMapReduce<V,KOut,VOut>mapReduce()ReturnsRMapReduceobject associated with this objectbooleanmove(String destination, V member)Move a member from this set to the given destination set in.RFuture<Boolean>moveAsync(String destination, V member)Move a member from this set to the given destination set in async mode.Vrandom()Returns random elementSet<V>random(int count)Returns random elements from set limited bycountRFuture<V>randomAsync()Returns random element from set in async modeRFuture<Set<V>>randomAsync(int count)Returns random elements from set limited bycountSet<V>readAll()Read all elements at onceRFuture<Set<V>>readAllAsync()Read all elements at onceSet<V>readDiff(String... names)Diff sets specified by name with current set.RFuture<Set<V>>readDiffAsync(String... names)Diff sets specified by name with current set.Set<V>readIntersection(String... names)Intersection sets specified by name with current set without current set state change.RFuture<Set<V>>readIntersectionAsync(String... names)Intersection sets specified by name with current set.<T> Collection<T>readSort(String byPattern, List<String> getPatterns, SortOrder order)Read data in sorted view<T> Collection<T>readSort(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Read data in sorted viewSet<V>readSort(String byPattern, SortOrder order)Read data in sorted viewSet<V>readSort(String byPattern, SortOrder order, int offset, int count)Read data in sorted viewSet<V>readSort(SortOrder order)Read data in sorted viewSet<V>readSort(SortOrder order, int offset, int count)Read data in sorted view<T> Collection<T>readSortAlpha(String byPattern, List<String> getPatterns, SortOrder order)Read data in sorted view lexicographically<T> Collection<T>readSortAlpha(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Read data in sorted view lexicographicallySet<V>readSortAlpha(String byPattern, SortOrder order)Read data in sorted view lexicographicallySet<V>readSortAlpha(String byPattern, SortOrder order, int offset, int count)Read data in sorted view lexicographicallySet<V>readSortAlpha(SortOrder order)Read data in sorted view lexicographicallySet<V>readSortAlpha(SortOrder order, int offset, int count)Read data in sorted view lexicographically<T> RFuture<Collection<T>>readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order)Read data in sorted view lexicographically<T> RFuture<Collection<T>>readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Read data in sorted view lexicographicallyRFuture<Set<V>>readSortAlphaAsync(String byPattern, SortOrder order)Read data in sorted view lexicographicallyRFuture<Set<V>>readSortAlphaAsync(String byPattern, SortOrder order, int offset, int count)Read data in sorted view lexicographicallyRFuture<Set<V>>readSortAlphaAsync(SortOrder order)Read data in sorted view lexicographicallyRFuture<Set<V>>readSortAlphaAsync(SortOrder order, int offset, int count)Read data in sorted view lexicographically<T> RFuture<Collection<T>>readSortAsync(String byPattern, List<String> getPatterns, SortOrder order)Read data in sorted view<T> RFuture<Collection<T>>readSortAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Read data in sorted viewRFuture<Set<V>>readSortAsync(String byPattern, SortOrder order)Read data in sorted viewRFuture<Set<V>>readSortAsync(String byPattern, SortOrder order, int offset, int count)Read data in sorted viewRFuture<Set<V>>readSortAsync(SortOrder order)Read data in sorted viewRFuture<Set<V>>readSortAsync(SortOrder order, int offset, int count)Read data in sorted viewSet<V>readUnion(String... names)Union sets specified by name with current set without current set state change.RFuture<Set<V>>readUnionAsync(String... names)Union sets specified by name with current set.longremainTimeToLive()Remaining time to live of Redisson object that has a timeoutRFuture<Long>remainTimeToLiveAsync()Remaining time to live of Redisson object that has a timeoutbooleanremove(Object value)booleanremoveAll(Collection<?> c)RFuture<Boolean>removeAllAsync(Collection<?> c)Removes all of this collection's elements that are also contained in the specified collection.RFuture<Boolean>removeAsync(Object o)Removes a single instance of the specified element from this collection, if it is present.VremoveRandom()Removes and returns random elementSet<V>removeRandom(int amount)Removes and returns random elements limited byamountRFuture<V>removeRandomAsync()Removes and returns random element from set in async modeRFuture<Set<V>>removeRandomAsync(int amount)Removes and returns random elements from set in async modebooleanretainAll(Collection<?> c)RFuture<Boolean>retainAllAsync(Collection<?> c)Retains only the elements in this collection that are contained in the specified collection.ScanResult<Object>scanIterator(String name, RedisClient client, long startPos, String pattern, int count)RFuture<ScanResult<Object>>scanIteratorAsync(String name, RedisClient client, long startPos, String pattern, int count)intsize()RFuture<Integer>sizeAsync()Returns number of elements in this collection.intsortTo(String destName, String byPattern, List<String> getPatterns, SortOrder order)Sort data and store todestNamelistintsortTo(String destName, String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Sort data and store todestNamelistintsortTo(String destName, String byPattern, SortOrder order)Sort data and store todestNamelistintsortTo(String destName, String byPattern, SortOrder order, int offset, int count)Sort data and store todestNamelistintsortTo(String destName, SortOrder order)Sort data and store todestNamelistintsortTo(String destName, SortOrder order, int offset, int count)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, String byPattern, List<String> getPatterns, SortOrder order)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, String byPattern, SortOrder order)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, String byPattern, SortOrder order, int offset, int count)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, SortOrder order)Sort data and store todestNamelistRFuture<Integer>sortToAsync(String destName, SortOrder order, int offset, int count)Sort data and store todestNamelistStream<V>stream(int count)Returns stream of elements fetches elements in a batch.Stream<V>stream(String pattern)Returns stream of elements.Stream<V>stream(String pattern, int count)Returns stream of elements fetches elements in a batch.Object[]toArray()<T> T[]toArray(T[] a)StringtoString()booleantryAdd(V... values)Tries to add elements only if none of them in set.RFuture<Boolean>tryAddAsync(V... values)Tries to add elements only if none of them in set.intunion(String... names)Union sets specified by name and write to current set.RFuture<Integer>unionAsync(String... names)Union sets specified by name and write to current set.-
Methods inherited from class org.redisson.RedissonObject
addListener, addListener, addListenerAsync, addListenerAsync, copy, copyAsync, delete, deleteAsync, deleteAsync, dump, dumpAsync, encode, encode, encode, encode, encodeMapKey, encodeMapKeys, encodeMapValue, encodeMapValues, get, getCodec, getIdleTime, getIdleTimeAsync, getLockByMapKey, getLockByValue, getName, getRawName, getRawName, isExists, isExistsAsync, migrate, migrateAsync, move, moveAsync, prefixName, removeListener, removeListenerAsync, removeListenersAsync, rename, renameAsync, renamenx, renamenxAsync, restore, restore, restoreAndReplace, restoreAndReplace, restoreAndReplaceAsync, restoreAndReplaceAsync, restoreAsync, restoreAsync, setName, sizeInMemory, sizeInMemoryAsync, sizeInMemoryAsync, sizeInMemoryAsync, suffixName, toSeconds, toStream, touch, touchAsync, unlink, unlinkAsync
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.Collection
parallelStream, removeIf, stream, toArray
-
Methods inherited from interface org.redisson.api.RExpirable
clearExpire, expire, expire, expireAt, expireAt, remainTimeToLive
-
Methods inherited from interface org.redisson.api.RExpirableAsync
clearExpireAsync, expireAsync, expireAsync, expireAtAsync, expireAtAsync, remainTimeToLiveAsync
-
Methods inherited from interface org.redisson.api.RObject
addListener, copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink
-
Methods inherited from interface org.redisson.api.RObjectAsync
addListenerAsync, copyAsync, deleteAsync, dumpAsync, getIdleTimeAsync, isExistsAsync, migrateAsync, moveAsync, removeListenerAsync, renameAsync, renamenxAsync, restoreAndReplaceAsync, restoreAndReplaceAsync, restoreAsync, restoreAsync, sizeInMemoryAsync, touchAsync, unlinkAsync
-
Methods inherited from interface java.util.Set
equals, hashCode, spliterator
-
-
-
-
Constructor Detail
-
RedissonSet
public RedissonSet(CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
RedissonSet
public RedissonSet(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
-
Method Detail
-
mapReduce
public <KOut,VOut> RCollectionMapReduce<V,KOut,VOut> mapReduce()
Description copied from interface:RSetReturnsRMapReduceobject associated with this object
-
size
public int size()
-
sizeAsync
public RFuture<Integer> sizeAsync()
Description copied from interface:RCollectionAsyncReturns number of elements in this collection.- Specified by:
sizeAsyncin interfaceRCollectionAsync<V>- Returns:
- size of collection
-
isEmpty
public boolean isEmpty()
-
contains
public boolean contains(Object o)
-
containsAsync
public RFuture<Boolean> containsAsync(Object o)
Description copied from interface:RCollectionAsyncReturnstrueif this collection contains encoded state of the specified element.- Specified by:
containsAsyncin interfaceRCollectionAsync<V>- Parameters:
o- element whose presence in this collection is to be tested- Returns:
trueif this collection contains the specified element andfalseotherwise
-
scanIterator
public ScanResult<Object> scanIterator(String name, RedisClient client, long startPos, String pattern, int count)
- Specified by:
scanIteratorin interfaceScanIterator
-
iterator
public Iterator<V> iterator(int count)
Description copied from interface:RSetReturns elements iterator fetches elements in a batch. Batch size is defined bycountparam.
-
iterator
public Iterator<V> iterator(String pattern)
Description copied from interface:RSetReturns elements iterator. Ifpatternis not null then only elements match this pattern are loaded.
-
iterator
public Iterator<V> iterator(String pattern, int count)
Description copied from interface:RSetReturns elements iterator fetches elements in a batch. Batch size is defined bycountparam. If pattern is not null then only elements match this pattern are loaded.
-
readAllAsync
public RFuture<Set<V>> readAllAsync()
Description copied from interface:RSetAsyncRead all elements at once- Specified by:
readAllAsyncin interfaceRSetAsync<V>- Returns:
- values
-
toArray
public Object[] toArray()
-
toArray
public <T> T[] toArray(T[] a)
-
add
public boolean add(V e)
-
addAsync
public RFuture<Boolean> addAsync(V e)
Description copied from interface:RCollectionAsyncAdds element into this collection.- Specified by:
addAsyncin interfaceRCollectionAsync<V>- Parameters:
e- - element to add- Returns:
trueif an element was added andfalseif it is already present
-
removeRandom
public V removeRandom()
Description copied from interface:RSetRemoves and returns random element- Specified by:
removeRandomin interfaceRSet<V>- Returns:
- random element
-
removeRandomAsync
public RFuture<V> removeRandomAsync()
Description copied from interface:RSetAsyncRemoves and returns random element from set in async mode- Specified by:
removeRandomAsyncin interfaceRSetAsync<V>- Returns:
- value
-
removeRandom
public Set<V> removeRandom(int amount)
Description copied from interface:RSetRemoves and returns random elements limited byamount- Specified by:
removeRandomin interfaceRSet<V>- Parameters:
amount- of random elements- Returns:
- random elements
-
removeRandomAsync
public RFuture<Set<V>> removeRandomAsync(int amount)
Description copied from interface:RSetAsyncRemoves and returns random elements from set in async mode- Specified by:
removeRandomAsyncin interfaceRSetAsync<V>- Parameters:
amount- of random values- Returns:
- random values
-
randomAsync
public RFuture<V> randomAsync()
Description copied from interface:RSetAsyncReturns random element from set in async mode- Specified by:
randomAsyncin interfaceRSetAsync<V>- Returns:
- value
-
random
public Set<V> random(int count)
Description copied from interface:RSetReturns random elements from set limited bycount
-
randomAsync
public RFuture<Set<V>> randomAsync(int count)
Description copied from interface:RSetAsyncReturns random elements from set limited bycount- Specified by:
randomAsyncin interfaceRSetAsync<V>- Parameters:
count- - values amount to return- Returns:
- value
-
removeAsync
public RFuture<Boolean> removeAsync(Object o)
Description copied from interface:RCollectionAsyncRemoves a single instance of the specified element from this collection, if it is present.- Specified by:
removeAsyncin interfaceRCollectionAsync<V>- Parameters:
o- element to be removed from this collection, if present- Returns:
trueif an element was removed as a result of this call
-
remove
public boolean remove(Object value)
- Specified by:
removein interfaceCollection<V>- Specified by:
removein interfaceScanIterator- Specified by:
removein interfaceSet<V>
-
moveAsync
public RFuture<Boolean> moveAsync(String destination, V member)
Description copied from interface:RSetAsyncMove a member from this set to the given destination set in async mode.
-
move
public boolean move(String destination, V member)
Description copied from interface:RSetMove a member from this set to the given destination set in.
-
containsAll
public boolean containsAll(Collection<?> c)
- Specified by:
containsAllin interfaceCollection<V>- Specified by:
containsAllin interfaceSet<V>
-
containsAllAsync
public RFuture<Boolean> containsAllAsync(Collection<?> c)
Description copied from interface:RCollectionAsyncReturnstrueif this collection contains all of the elements in the specified collection.- Specified by:
containsAllAsyncin interfaceRCollectionAsync<V>- Parameters:
c- collection to be checked for containment in this collection- Returns:
trueif this collection contains all of the elements in the specified collection
-
addAll
public boolean addAll(Collection<? extends V> c)
-
addAllAsync
public RFuture<Boolean> addAllAsync(Collection<? extends V> c)
Description copied from interface:RCollectionAsyncAdds all elements contained in the specified collection- Specified by:
addAllAsyncin interfaceRCollectionAsync<V>- Parameters:
c- - collection of elements to add- Returns:
trueif at least one element was added andfalseif all elements are already present
-
retainAll
public boolean retainAll(Collection<?> c)
-
retainAllAsync
public RFuture<Boolean> retainAllAsync(Collection<?> c)
Description copied from interface:RCollectionAsyncRetains only the elements in this collection that are contained in the specified collection.- Specified by:
retainAllAsyncin interfaceRCollectionAsync<V>- Parameters:
c- collection containing elements to be retained in this collection- Returns:
trueif this collection changed as a result of the call
-
removeAllAsync
public RFuture<Boolean> removeAllAsync(Collection<?> c)
Description copied from interface:RCollectionAsyncRemoves all of this collection's elements that are also contained in the specified collection.- Specified by:
removeAllAsyncin interfaceRCollectionAsync<V>- Parameters:
c- collection containing elements to be removed from this collection- Returns:
trueif this collection changed as a result of the call
-
removeAll
public boolean removeAll(Collection<?> c)
-
union
public int union(String... names)
Description copied from interface:RSetUnion sets specified by name and write to current set. If current set already exists, it is overwritten.
-
unionAsync
public RFuture<Integer> unionAsync(String... names)
Description copied from interface:RSetAsyncUnion sets specified by name and write to current set. If current set already exists, it is overwritten.- Specified by:
unionAsyncin interfaceRSetAsync<V>- Parameters:
names- - name of sets- Returns:
- size of union
-
readUnion
public Set<V> readUnion(String... names)
Description copied from interface:RSetUnion sets specified by name with current set without current set state change.
-
readUnionAsync
public RFuture<Set<V>> readUnionAsync(String... names)
Description copied from interface:RSetAsyncUnion sets specified by name with current set. Without current set state change.- Specified by:
readUnionAsyncin interfaceRSetAsync<V>- Parameters:
names- - name of sets- Returns:
- values
-
diff
public int diff(String... names)
Description copied from interface:RSetDiff sets specified by name and write to current set. If current set already exists, it is overwritten.
-
diffAsync
public RFuture<Integer> diffAsync(String... names)
Description copied from interface:RSetAsyncDiff sets specified by name and write to current set. If current set already exists, it is overwritten.
-
readDiff
public Set<V> readDiff(String... names)
Description copied from interface:RSetDiff sets specified by name with current set. Without current set state change.
-
readDiffAsync
public RFuture<Set<V>> readDiffAsync(String... names)
Description copied from interface:RSetAsyncDiff sets specified by name with current set. Without current set state change.- Specified by:
readDiffAsyncin interfaceRSetAsync<V>- Parameters:
names- - name of sets- Returns:
- values
-
intersection
public int intersection(String... names)
Description copied from interface:RSetIntersection sets specified by name and write to current set. If current set already exists, it is overwritten.- Specified by:
intersectionin interfaceRSet<V>- Parameters:
names- - name of sets- Returns:
- size of intersection
-
intersectionAsync
public RFuture<Integer> intersectionAsync(String... names)
Description copied from interface:RSetAsyncIntersection sets specified by name and write to current set. If current set already exists, it is overwritten.- Specified by:
intersectionAsyncin interfaceRSetAsync<V>- Parameters:
names- - name of sets- Returns:
- size of intersection
-
readIntersection
public Set<V> readIntersection(String... names)
Description copied from interface:RSetIntersection sets specified by name with current set without current set state change.- Specified by:
readIntersectionin interfaceRSet<V>- Parameters:
names- - name of sets- Returns:
- values
-
readIntersectionAsync
public RFuture<Set<V>> readIntersectionAsync(String... names)
Description copied from interface:RSetAsyncIntersection sets specified by name with current set. Without current set state change.- Specified by:
readIntersectionAsyncin interfaceRSetAsync<V>- Parameters:
names- - name of sets- Returns:
- values
-
clear
public void clear()
-
readSort
public Set<V> readSort(SortOrder order)
Description copied from interface:RSortableRead data in sorted view
-
readSortAsync
public RFuture<Set<V>> readSortAsync(SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Parameters:
order- for sorted data- Returns:
- sorted collection
-
readSort
public Set<V> readSort(SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view
-
readSortAsync
public RFuture<Set<V>> readSortAsync(SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Parameters:
order- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection
-
readSort
public Set<V> readSort(String byPattern, SortOrder order)
Description copied from interface:RSortableRead data in sorted view
-
readSortAsync
public RFuture<Set<V>> readSortAsync(String byPattern, SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted data- Returns:
- sorted collection
-
readSort
public Set<V> readSort(String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view
-
readSortAsync
public RFuture<Set<V>> readSortAsync(String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection
-
readSort
public <T> Collection<T> readSort(String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableRead data in sorted view
-
readSortAsync
public <T> RFuture<Collection<T>> readSortAsync(String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted data- Returns:
- sorted collection
-
readSort
public <T> Collection<T> readSort(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view- Specified by:
readSortin interfaceRSortable<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection
-
readSortAsync
public <T> RFuture<Collection<T>> readSortAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view- Specified by:
readSortAsyncin interfaceRSortableAsync<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection
-
readSortAlpha
public Set<V> readSortAlpha(SortOrder order)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Parameters:
order- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlpha
public Set<V> readSortAlpha(SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Parameters:
order- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
readSortAlpha
public Set<V> readSortAlpha(String byPattern, SortOrder order)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlpha
public Set<V> readSortAlpha(String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
readSortAlpha
public <T> Collection<T> readSortAlpha(String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlpha
public <T> Collection<T> readSortAlpha(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableRead data in sorted view lexicographically- Specified by:
readSortAlphain interfaceRSortable<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public RFuture<Set<V>> readSortAlphaAsync(SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Parameters:
order- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public RFuture<Set<V>> readSortAlphaAsync(SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Parameters:
order- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public RFuture<Set<V>> readSortAlphaAsync(String byPattern, SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public RFuture<Set<V>> readSortAlphaAsync(String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Parameters:
byPattern- that is used to generate the keys that are used for sortingorder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public <T> RFuture<Collection<T>> readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted data- Returns:
- sorted collection lexicographically
-
readSortAlphaAsync
public <T> RFuture<Collection<T>> readSortAlphaAsync(String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncRead data in sorted view lexicographically- Specified by:
readSortAlphaAsyncin interfaceRSortableAsync<V>- Type Parameters:
T- object type- Parameters:
byPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- sorted collection lexicographically
-
sortTo
public int sortTo(String destName, SortOrder order)
Description copied from interface:RSortableSort data and store todestNamelist
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, SortOrder order)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationorder- for sorted data- Returns:
- length of sorted data
-
sortTo
public int sortTo(String destName, SortOrder order, int offset, int count)
Description copied from interface:RSortableSort data and store todestNamelist
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationorder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- length of sorted data
-
sortTo
public int sortTo(String destName, String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableSort data and store todestNamelist
-
sortTo
public int sortTo(String destName, String byPattern, SortOrder order)
Description copied from interface:RSortableSort data and store todestNamelist
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, String byPattern, SortOrder order)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationbyPattern- that is used to generate the keys that are used for sortingorder- for sorted data- Returns:
- length of sorted data
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, String byPattern, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationbyPattern- that is used to generate the keys that are used for sortingorder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- length of sorted data
-
sortTo
public int sortTo(String destName, String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableSort data and store todestNamelist
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, String byPattern, List<String> getPatterns, SortOrder order)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationbyPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted data- Returns:
- length of sorted data
-
sortTo
public int sortTo(String destName, String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableSort data and store todestNamelist- Specified by:
sortToin interfaceRSortable<V>- Parameters:
destName- list object destinationbyPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- length of sorted data
-
sortToAsync
public RFuture<Integer> sortToAsync(String destName, String byPattern, List<String> getPatterns, SortOrder order, int offset, int count)
Description copied from interface:RSortableAsyncSort data and store todestNamelist- Specified by:
sortToAsyncin interfaceRSortableAsync<V>- Parameters:
destName- list object destinationbyPattern- that is used to generate the keys that are used for sortinggetPatterns- that is used to load values by keys in sorted vieworder- for sorted dataoffset- of sorted datacount- of sorted data- Returns:
- length of sorted data
-
tryAdd
public boolean tryAdd(V... values)
Description copied from interface:RSetTries to add elements only if none of them in set.
-
tryAddAsync
public RFuture<Boolean> tryAddAsync(V... values)
Description copied from interface:RSetAsyncTries to add elements only if none of them in set.- Specified by:
tryAddAsyncin interfaceRSetAsync<V>- Parameters:
values- - values to add- Returns:
trueif elements successfully added, otherwisefalse.
-
getPermitExpirableSemaphore
public RPermitExpirableSemaphore getPermitExpirableSemaphore(V value)
Description copied from interface:RSetReturnsRPermitExpirableSemaphoreinstance associated withvalue- Specified by:
getPermitExpirableSemaphorein interfaceRSet<V>- Parameters:
value- - set value- Returns:
- RPermitExpirableSemaphore object
-
getSemaphore
public RSemaphore getSemaphore(V value)
Description copied from interface:RSetReturnsRSemaphoreinstance associated withvalue- Specified by:
getSemaphorein interfaceRSet<V>- Parameters:
value- - set value- Returns:
- RSemaphore object
-
getCountDownLatch
public RCountDownLatch getCountDownLatch(V value)
Description copied from interface:RSetReturnsRCountDownLatchinstance associated withvalue- Specified by:
getCountDownLatchin interfaceRSet<V>- Parameters:
value- - set value- Returns:
- RCountDownLatch object
-
getFairLock
public RLock getFairLock(V value)
Description copied from interface:RSetReturnsRLockinstance associated withvalue- Specified by:
getFairLockin interfaceRSet<V>- Parameters:
value- - set value- Returns:
- RLock object
-
getLock
public RLock getLock(V value)
Description copied from interface:RSetReturns lock instance associated withvalue
-
getReadWriteLock
public RReadWriteLock getReadWriteLock(V value)
Description copied from interface:RSetReturnsRReadWriteLockinstance associated withvalue- Specified by:
getReadWriteLockin interfaceRSet<V>- Parameters:
value- - set value- Returns:
- RReadWriteLock object
-
scanIteratorAsync
public RFuture<ScanResult<Object>> scanIteratorAsync(String name, RedisClient client, long startPos, String pattern, int count)
- Specified by:
scanIteratorAsyncin interfaceScanIterator
-
stream
public Stream<V> stream(int count)
Description copied from interface:RSetReturns stream of elements fetches elements in a batch. Batch size is defined bycountparam.
-
stream
public Stream<V> stream(String pattern, int count)
Description copied from interface:RSetReturns stream of elements fetches elements in a batch. Batch size is defined bycountparam. If pattern is not null then only elements match this pattern are loaded.
-
stream
public Stream<V> stream(String pattern)
Description copied from interface:RSetReturns stream of elements. If pattern is not null then only elements match this pattern are loaded.
-
expire
public boolean expire(long timeToLive, TimeUnit timeUnit)Description copied from interface:RExpirableSet a timeout for object. After the timeout has expired, the key will automatically be deleted.- Specified by:
expirein interfaceRExpirable- Parameters:
timeToLive- - timeout before object will be deletedtimeUnit- - timeout time unit- Returns:
trueif the timeout was set andfalseif not
-
expireAsync
public RFuture<Boolean> expireAsync(long timeToLive, TimeUnit timeUnit)
Description copied from interface:RExpirableAsyncSet a timeout for object in async mode. After the timeout has expired, the key will automatically be deleted.- Specified by:
expireAsyncin interfaceRExpirableAsync- Parameters:
timeToLive- - timeout before object will be deletedtimeUnit- - timeout time unit- Returns:
trueif the timeout was set andfalseif not
-
expireAt
public boolean expireAt(long timestamp)
Description copied from interface:RExpirableUseRExpirable.expire(Instant)instead- Specified by:
expireAtin interfaceRExpirable- Parameters:
timestamp- - expire date in milliseconds (Unix timestamp)- Returns:
trueif the timeout was set andfalseif not
-
expireAtAsync
public RFuture<Boolean> expireAtAsync(long timestamp)
Description copied from interface:RExpirableAsyncUseRExpirableAsync.expireAsync(Instant)instead- Specified by:
expireAtAsyncin interfaceRExpirableAsync- Parameters:
timestamp- - expire date in milliseconds (Unix timestamp)- Returns:
trueif the timeout was set andfalseif not
-
expire
public boolean expire(Instant instant)
Description copied from interface:RExpirableSet an expire date for object. When expire date comes the key will automatically be deleted.- Specified by:
expirein interfaceRExpirable- Parameters:
instant- - expire date- Returns:
trueif the timeout was set andfalseif not
-
expireAsync
public RFuture<Boolean> expireAsync(Instant instant)
Description copied from interface:RExpirableAsyncSet an expire date for object. When expire date comes the key will automatically be deleted.- Specified by:
expireAsyncin interfaceRExpirableAsync- Parameters:
instant- - expire date- Returns:
trueif the timeout was set andfalseif not
-
expireAt
public boolean expireAt(Date timestamp)
Description copied from interface:RExpirableUseRExpirable.expire(Instant)instead- Specified by:
expireAtin interfaceRExpirable- Parameters:
timestamp- - expire date- Returns:
trueif the timeout was set andfalseif not
-
expireAtAsync
public RFuture<Boolean> expireAtAsync(Date timestamp)
Description copied from interface:RExpirableAsyncUseRExpirableAsync.expireAsync(Instant)instead- Specified by:
expireAtAsyncin interfaceRExpirableAsync- Parameters:
timestamp- - expire date- Returns:
trueif the timeout was set andfalseif not
-
clearExpire
public boolean clearExpire()
Description copied from interface:RExpirableClear an expire timeout or expire date for object.- Specified by:
clearExpirein interfaceRExpirable- Returns:
trueif timeout was removedfalseif object does not exist or does not have an associated timeout
-
clearExpireAsync
public RFuture<Boolean> clearExpireAsync()
Description copied from interface:RExpirableAsyncClear an expire timeout or expire date for object in async mode. Object will not be deleted.- Specified by:
clearExpireAsyncin interfaceRExpirableAsync- Returns:
trueif the timeout was cleared andfalseif not
-
remainTimeToLive
public long remainTimeToLive()
Description copied from interface:RExpirableRemaining time to live of Redisson object that has a timeout- Specified by:
remainTimeToLivein interfaceRExpirable- Returns:
- time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
-
remainTimeToLiveAsync
public RFuture<Long> remainTimeToLiveAsync()
Description copied from interface:RExpirableAsyncRemaining time to live of Redisson object that has a timeout- Specified by:
remainTimeToLiveAsyncin interfaceRExpirableAsync- Returns:
- time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
-
expireAsync
protected RFuture<Boolean> expireAsync(long timeToLive, TimeUnit timeUnit, String... keys)
-
-