Class RedissonScoredSortedSet<V>
- java.lang.Object
-
- org.redisson.RedissonObject
-
- org.redisson.RedissonScoredSortedSet<V>
-
- Type Parameters:
V- value type
- All Implemented Interfaces:
Iterable<V>,RExpirable,RExpirableAsync,RObject,RObjectAsync,RScoredSortedSet<V>,RScoredSortedSetAsync<V>,RSortable<Set<V>>,RSortableAsync<Set<V>>
- Direct Known Subclasses:
RedissonGeo,RedissonLexSortedSet
public class RedissonScoredSortedSet<V> extends RedissonObject implements RScoredSortedSet<V>
- Author:
- Nikita Koksharov
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.redisson.api.RScoredSortedSet
RScoredSortedSet.Aggregate
-
-
Field Summary
-
Fields inherited from class org.redisson.RedissonObject
codec, commandExecutor, name
-
-
Constructor Summary
Constructors Constructor Description RedissonScoredSortedSet(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)RedissonScoredSortedSet(CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadd(double score, V object)Adds element to this set, overrides previous score if it has been already added.intaddAll(Map<V,Double> objects)Adds all elements contained in the specified map to this sorted set.RFuture<Integer>addAllAsync(Map<V,Double> objects)Adds all elements contained in the specified map to this sorted set.IntegeraddAndGetRank(double score, V object)Adds element to this set, overrides previous score if it has been already added.RFuture<Integer>addAndGetRankAsync(double score, V object)Adds element to this set, overrides previous score if it has been already added.IntegeraddAndGetRevRank(double score, V object)Adds element to this set, overrides previous score if it has been already added.List<Integer>addAndGetRevRank(Map<? extends V,Double> map)Adds elements to this set, overrides previous score if it has been already added.RFuture<Integer>addAndGetRevRankAsync(double score, V object)Adds element to this set, overrides previous score if it has been already added.RFuture<List<Integer>>addAndGetRevRankAsync(Map<? extends V,Double> map)Adds elements to this set, overrides previous score if it has been already added.RFuture<Boolean>addAsync(double score, V object)Adds element to this set, overrides previous score if it has been already added.booleanaddIfExists(double score, V object)Adds element to this set only if it's already exists.RFuture<Boolean>addIfExistsAsync(double score, V object)Adds element to this set only if it's already exists.booleanaddIfGreater(double score, V object)Adds element to this set only if new score greater than current score of existed element.RFuture<Boolean>addIfGreaterAsync(double score, V object)Adds element to this set only if new score greater than current score of existed element.booleanaddIfLess(double score, V object)Adds element to this set only if new score less than current score of existed element.RFuture<Boolean>addIfLessAsync(double score, V object)Adds element to this set only if new score less than current score of existed element.intaddListener(ObjectListener listener)Adds object event listenerRFuture<Integer>addListenerAsync(ObjectListener listener)Adds object event listenerDoubleaddScore(V object, Number value)Increases score of specified element by value.IntegeraddScoreAndGetRank(V object, Number value)Adds score to element and returns its rankRFuture<Integer>addScoreAndGetRankAsync(V object, Number value)Adds score to element and returns its rankIntegeraddScoreAndGetRevRank(V object, Number value)Adds score to element and returns its reverse rankRFuture<Integer>addScoreAndGetRevRankAsync(V object, Number value)Adds score to element and returns its reverse rankRFuture<Double>addScoreAsync(V object, Number value)Increases score of specified element by value.voidclear()Removes all elements of this sorted set.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 object)Returnstrueif this sorted set contains encoded state of the specified element.booleancontainsAll(Collection<?> c)Returnstrueif this sorted set contains all of the elements in encoded state in the specified collection.RFuture<Boolean>containsAllAsync(Collection<?> c)Returnstrueif this sorted set contains all of the elements in encoded state in the specified collection.RFuture<Boolean>containsAsync(Object o)Returnstrueif this sorted set contains encoded state of the specified element.intcount(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns the number of elements with a score betweenstartScoreandendScore.RFuture<Integer>countAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns the number of elements with a score betweenstartScoreandendScore.intdiff(String... names)Diff provided ScoredSortedSets and store result to current ScoredSortedSetRFuture<Integer>diffAsync(String... names)Diff provided ScoredSortedSets and store result to current ScoredSortedSetCollection<ScoredEntry<V>>entryRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all entries (value and its score) betweenstartScoreandendScore.Collection<ScoredEntry<V>>entryRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all entries (value and its score) betweenstartScoreandendScore.Collection<ScoredEntry<V>>entryRange(int startIndex, int endIndex)Returns entries (value and its score) by rank range.RFuture<Collection<ScoredEntry<V>>>entryRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all entries (value and its score) betweenstartScoreandendScore.RFuture<Collection<ScoredEntry<V>>>entryRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all entries (value and its score) betweenstartScoreandendScore.RFuture<Collection<ScoredEntry<V>>>entryRangeAsync(int startIndex, int endIndex)Returns entries (value and its score) by rank range.Collection<ScoredEntry<V>>entryRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all entries (value and its score) betweenstartScoreandendScorein reversed order.Collection<ScoredEntry<V>>entryRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all entries (value and its score) betweenstartScoreandendScorein reversed order.Collection<ScoredEntry<V>>entryRangeReversed(int startIndex, int endIndex)Returns entries (value and its score) by rank range in reverse order.RFuture<Collection<ScoredEntry<V>>>entryRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all entries (value and its score) betweenstartScoreandendScorein reversed order.RFuture<Collection<ScoredEntry<V>>>entryRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all entries (value and its score) betweenstartScoreandendScorein reversed order.RFuture<Collection<ScoredEntry<V>>>entryRangeReversedAsync(int startIndex, int endIndex)Returns entries (value and its score) by rank range in reverse order.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)insteadVfirst()Returns the head element ornullif this sorted set is empty.RFuture<V>firstAsync()Returns the head element ornullif this sorted set is empty.DoublefirstScore()Returns score of the tail element or returnsnullif this sorted set is empty.RFuture<Double>firstScoreAsync()Returns score of the head element or returnsnullif this sorted set is empty.List<Double>getScore(List<V> keys)Returns scores of elements.DoublegetScore(V o)Returns score of element ornullif it doesn't exist.RFuture<List<Double>>getScoreAsync(Collection<V> elements)Returns scores of elements.RFuture<Double>getScoreAsync(V o)Returns score of element ornullif it doesn't exist.intintersection(String... names)Intersect provided ScoredSortedSets and store result to current ScoredSortedSetintintersection(Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSetintintersection(RScoredSortedSet.Aggregate aggregate, String... names)Intersect provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSetintintersection(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSetRFuture<Integer>intersectionAsync(String... names)Intersect provided ScoredSortedSets and store result to current ScoredSortedSetRFuture<Integer>intersectionAsync(Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSetRFuture<Integer>intersectionAsync(RScoredSortedSet.Aggregate aggregate, String... names)Intersect provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSetRFuture<Integer>intersectionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSetbooleanisEmpty()Returnstrueif this set is emptyIterator<V>iterator()Iterator<V>iterator(int count)Returns an iterator over elements in this set.Iterator<V>iterator(String pattern)Returns an iterator over elements in this set.Iterator<V>iterator(String pattern, int count)Returns an iterator over elements in this set.Vlast()Returns the tail element ornullif this sorted set is empty.RFuture<V>lastAsync()Returns the tail element ornullif this sorted set is empty.DoublelastScore()Returns score of the head element or returnsnullif this sorted set is empty.RFuture<Double>lastScoreAsync()Returns score of the tail element or returnsnullif this sorted set is empty.<KOut,VOut>
RCollectionMapReduce<V,KOut,VOut>mapReduce()ReturnsRMapReduceobject associated with this objectVpollFirst()Removes and returns the head element ornullif this sorted set is empty.Collection<V>pollFirst(int count)Removes and returns the head elements of this sorted set.VpollFirst(long timeout, TimeUnit unit)Removes and returns the head element ornullif this sorted set is empty.RFuture<V>pollFirstAsync()Removes and returns the head element ornullif this sorted set is empty.RFuture<Collection<V>>pollFirstAsync(int count)Removes and returns the head elements of this sorted set.RFuture<V>pollFirstAsync(long timeout, TimeUnit unit)Removes and returns the head element ornullif this sorted set is empty.VpollFirstFromAny(long timeout, TimeUnit unit, String... queueNames)Removes and returns first available head element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.RFuture<V>pollFirstFromAnyAsync(long timeout, TimeUnit unit, String... queueNames)Removes and returns first available head element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.VpollLast()Removes and returns the tail element ornullif this sorted set is empty.Collection<V>pollLast(int count)Removes and returns the tail elements of this sorted set.VpollLast(long timeout, TimeUnit unit)Removes and returns the tail element ornullif this sorted set is empty.RFuture<V>pollLastAsync()Removes and returns the tail element ornullif this sorted set is empty.RFuture<Collection<V>>pollLastAsync(int count)Removes and returns the tail elements of this sorted set.RFuture<V>pollLastAsync(long timeout, TimeUnit unit)Removes and returns the tail element ornullif this sorted set is empty.VpollLastFromAny(long timeout, TimeUnit unit, String... queueNames)Removes and returns first available tail element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.RFuture<V>pollLastFromAnyAsync(long timeout, TimeUnit unit, String... queueNames)Removes and returns first available tail element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.Vrandom()Returns random element from this sorted setCollection<V>random(int count)Returns random elements from this sorted set limited bycountRFuture<V>randomAsync()Returns random element from this sorted setRFuture<Collection<V>>randomAsync(int count)Returns random elements from this sorted set limited bycountMap<V,Double>randomEntries(int count)Returns random entries from this sorted set limited bycount.RFuture<Map<V,Double>>randomEntriesAsync(int count)Returns random entries from this sorted set limited bycount.intrangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Stores to defined ScoredSortedSet values betweenstartScoreandendScore.intrangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Stores to defined ScoredSortedSet values betweenstartScoreandendScore.intrangeTo(String destName, int startIndex, int endIndex)Stores to defined ScoredSortedSet values by rank range.RFuture<Integer>rangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Stores to defined ScoredSortedSet values betweenstartScoreandendScore.RFuture<Integer>rangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Stores to defined ScoredSortedSet values betweenstartScoreandendScore.RFuture<Integer>rangeToAsync(String destName, int startIndex, int endIndex)Stores to defined ScoredSortedSet values by rank range.Integerrank(V o)Returns rank of value, with the scores ordered from low to high.RFuture<Integer>rankAsync(V o)Returns rank of value, with the scores ordered from low to high.Collection<V>readAll()Read all values at once.RFuture<Collection<V>>readAllAsync()Read all values at once.Collection<V>readDiff(String... names)Diff ScoredSortedSets specified by name with current ScoredSortedSet without state change.RFuture<Collection<V>>readDiffAsync(String... names)Diff ScoredSortedSets specified by name with current ScoredSortedSet without state change.Collection<V>readIntersection(String... names)Intersect provided ScoredSortedSets with current ScoredSortedSet without state changeCollection<V>readIntersection(Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet without state changeCollection<V>readIntersection(RScoredSortedSet.Aggregate aggregate, String... names)Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method without state changeCollection<V>readIntersection(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet using defined aggregation method without state changeRFuture<Collection<V>>readIntersectionAsync(String... names)Intersect provided ScoredSortedSets with current ScoredSortedSet without state changeRFuture<Collection<V>>readIntersectionAsync(Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet without state changeRFuture<Collection<V>>readIntersectionAsync(RScoredSortedSet.Aggregate aggregate, String... names)Intersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method without state changeRFuture<Collection<V>>readIntersectionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Intersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet using defined aggregation method without state change<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 viewCollection<V>readUnion(String... names)Union ScoredSortedSets specified by name with current ScoredSortedSet without state change.Collection<V>readUnion(Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier and current ScoredSortedSet without state change.Collection<V>readUnion(RScoredSortedSet.Aggregate aggregate, String... names)Union ScoredSortedSets specified by name with defined aggregation method and current ScoredSortedSet without state change.Collection<V>readUnion(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and current ScoredSortedSet without state changeRFuture<Collection<V>>readUnionAsync(String... names)Union ScoredSortedSets specified by name with current ScoredSortedSet without state change.RFuture<Collection<V>>readUnionAsync(Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier and current ScoredSortedSet without state change.RFuture<Collection<V>>readUnionAsync(RScoredSortedSet.Aggregate aggregate, String... names)Union ScoredSortedSets specified by name with defined aggregation method and current ScoredSortedSet without state change.RFuture<Collection<V>>readUnionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and current ScoredSortedSet without state changelongremainTimeToLive()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 object)Removes a single instance of the specified element from this sorted set, if it is present.booleanremoveAll(Collection<?> c)Removes all of this sorted set's elements that are also contained in the specified collection.RFuture<Boolean>removeAllAsync(Collection<?> c)Removes all of this sorted set's elements that are also contained in the specified collection.RFuture<Boolean>removeAsync(Object object)Removes a single instance of the specified element from this sorted set, if it is present.voidremoveListener(int listenerId)Removes object event listenerRFuture<Void>removeListenerAsync(int listenerId)Removes object event listenerintremoveRangeByRank(int startIndex, int endIndex)Removes values by rank range.RFuture<Integer>removeRangeByRankAsync(int startIndex, int endIndex)Removes values by rank range.intremoveRangeByScore(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Removes values by score range.RFuture<Integer>removeRangeByScoreAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Removes values by score range.booleanretainAll(Collection<?> c)Retains only the elements in this sorted set that are contained in the specified collection.RFuture<Boolean>retainAllAsync(Collection<?> c)Retains only the elements in this sorted set that are contained in the specified collection.intrevRangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Stores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.intrevRangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Stores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.intrevRangeTo(String destName, int startIndex, int endIndex)Stores to defined ScoredSortedSet values in reversed order by rank range.RFuture<Integer>revRangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Stores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.RFuture<Integer>revRangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Stores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.RFuture<Integer>revRangeToAsync(String destName, int startIndex, int endIndex)Stores to defined ScoredSortedSet values in reversed order by rank range.List<Integer>revRank(Collection<V> elements)Returns ranks of elements, with the scores ordered from high to low.IntegerrevRank(V o)Returns rank of value, with the scores ordered from high to low.RFuture<List<Integer>>revRankAsync(Collection<V> elements)Returns ranks of elements, with the scores ordered from high to low.RFuture<Integer>revRankAsync(V o)Returns rank of value, with the scores ordered from high to low.RFuture<ScanResult<Object>>scanIteratorAsync(RedisClient client, long startPos, String pattern, int count)intsize()Returns size of this set.RFuture<Integer>sizeAsync()Returns size of this set.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()Returns stream of elements in this set.Stream<V>stream(int count)Returns stream of elements in this set.Stream<V>stream(String pattern)Returns stream of elements in this set.Stream<V>stream(String pattern, int count)Returns stream of elements in this set.intsubscribeOnFirstElements(Consumer<V> consumer)Subscribes on first elements appeared in this set.intsubscribeOnLastElements(Consumer<V> consumer)Subscribes on last elements appeared in this set.VtakeFirst()Removes and returns the head element waiting if necessary for an element to become available.RFuture<V>takeFirstAsync()Removes and returns the head element waiting if necessary for an element to become available.VtakeLast()Removes and returns the tail element waiting if necessary for an element to become available.RFuture<V>takeLastAsync()Removes and returns the tail element waiting if necessary for an element to become available.Object[]toArray()Returns this sorted set in array of Object type.<T> T[]toArray(T[] a)Returns this sorted set in array of defined type.booleantryAdd(double score, V object)Adds element to this set only if has not been added before.RFuture<Boolean>tryAddAsync(double score, V object)Adds element to this set only if has not been added before.intunion(String... names)Union provided ScoredSortedSets and store result to current ScoredSortedSetintunion(Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSetintunion(RScoredSortedSet.Aggregate aggregate, String... names)Union provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSetintunion(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSetRFuture<Integer>unionAsync(String... names)Union provided ScoredSortedSets and store result to current ScoredSortedSetRFuture<Integer>unionAsync(Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSetRFuture<Integer>unionAsync(RScoredSortedSet.Aggregate aggregate, String... names)Union provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSetRFuture<Integer>unionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)Union provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSetvoidunsubscribe(int listenerId)Un-subscribes defined listener.Collection<V>valueRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all values betweenstartScoreandendScore.Collection<V>valueRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all values betweenstartScoreandendScore.Collection<V>valueRange(int startIndex, int endIndex)Returns values by rank range.RFuture<Collection<V>>valueRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all values betweenstartScoreandendScore.RFuture<Collection<V>>valueRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all values betweenstartScoreandendScore.RFuture<Collection<V>>valueRangeAsync(int startIndex, int endIndex)Returns values by rank range.Collection<V>valueRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all values betweenstartScoreandendScorein reversed order.Collection<V>valueRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all values betweenstartScoreandendScorein reversed order.Collection<V>valueRangeReversed(int startIndex, int endIndex)Returns values by rank range in reverse order.RFuture<Collection<V>>valueRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Returns all values betweenstartScoreandendScorein reversed order.RFuture<Collection<V>>valueRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)Returns all values betweenstartScoreandendScorein reversed order.RFuture<Collection<V>>valueRangeReversedAsync(int startIndex, int endIndex)Returns values by rank range in reverse order.-
Methods inherited from class org.redisson.RedissonObject
addListener, 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, 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, toString, wait, wait, wait
-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
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
copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink
-
Methods inherited from interface org.redisson.api.RObjectAsync
copyAsync, deleteAsync, dumpAsync, getIdleTimeAsync, isExistsAsync, migrateAsync, moveAsync, renameAsync, renamenxAsync, restoreAndReplaceAsync, restoreAndReplaceAsync, restoreAsync, restoreAsync, sizeInMemoryAsync, touchAsync, unlinkAsync
-
-
-
-
Constructor Detail
-
RedissonScoredSortedSet
public RedissonScoredSortedSet(CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
RedissonScoredSortedSet
public RedissonScoredSortedSet(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson)
-
-
Method Detail
-
mapReduce
public <KOut,VOut> RCollectionMapReduce<V,KOut,VOut> mapReduce()
Description copied from interface:RScoredSortedSetReturnsRMapReduceobject associated with this object- Specified by:
mapReducein interfaceRScoredSortedSet<V>- Type Parameters:
KOut- output keyVOut- output value- Returns:
- MapReduce instance
-
readAll
public Collection<V> readAll()
Description copied from interface:RScoredSortedSetRead all values at once.- Specified by:
readAllin interfaceRScoredSortedSet<V>- Returns:
- values
-
readAllAsync
public RFuture<Collection<V>> readAllAsync()
Description copied from interface:RScoredSortedSetAsyncRead all values at once.- Specified by:
readAllAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- values
-
pollFirst
public V pollFirst()
Description copied from interface:RScoredSortedSetRemoves and returns the head element ornullif this sorted set is empty.- Specified by:
pollFirstin interfaceRScoredSortedSet<V>- Returns:
- the head element,
or
nullif this sorted set is empty
-
pollLast
public V pollLast()
Description copied from interface:RScoredSortedSetRemoves and returns the tail element ornullif this sorted set is empty.- Specified by:
pollLastin interfaceRScoredSortedSet<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
pollFirst
public Collection<V> pollFirst(int count)
Description copied from interface:RScoredSortedSetRemoves and returns the head elements of this sorted set.- Specified by:
pollFirstin interfaceRScoredSortedSet<V>- Parameters:
count- - elements amount- Returns:
- the head elements of this sorted set
-
pollLast
public Collection<V> pollLast(int count)
Description copied from interface:RScoredSortedSetRemoves and returns the tail elements of this sorted set.- Specified by:
pollLastin interfaceRScoredSortedSet<V>- Parameters:
count- - elements amount- Returns:
- the tail elements of this sorted set
-
pollFirstAsync
public RFuture<Collection<V>> pollFirstAsync(int count)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the head elements of this sorted set.- Specified by:
pollFirstAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
count- - elements amount- Returns:
- the head elements of this sorted set
-
pollLastAsync
public RFuture<Collection<V>> pollLastAsync(int count)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the tail elements of this sorted set.- Specified by:
pollLastAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
count- - elements amount- Returns:
- the tail elements of this sorted set
-
pollFirstAsync
public RFuture<V> pollFirstAsync()
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the head element ornullif this sorted set is empty.- Specified by:
pollFirstAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the head element,
or
nullif this sorted set is empty
-
pollLastAsync
public RFuture<V> pollLastAsync()
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the tail element ornullif this sorted set is empty.- Specified by:
pollLastAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
pollFirst
public V pollFirst(long timeout, TimeUnit unit)
Description copied from interface:RScoredSortedSetRemoves and returns the head element ornullif this sorted set is empty.- Specified by:
pollFirstin interfaceRScoredSortedSet<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameter- Returns:
- the head element,
or
nullif this sorted set is empty
-
pollFirstAsync
public RFuture<V> pollFirstAsync(long timeout, TimeUnit unit)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the head element ornullif this sorted set is empty.Requires Redis 5.0.0 and higher.
- Specified by:
pollFirstAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameter- Returns:
- the head element,
or
nullif this sorted set is empty
-
pollFirstFromAny
public V pollFirstFromAny(long timeout, TimeUnit unit, String... queueNames)
Description copied from interface:RScoredSortedSetRemoves and returns first available head element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.Requires Redis 5.0.0 and higher.
- Specified by:
pollFirstFromAnyin interfaceRScoredSortedSet<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameterqueueNames- - names of queue- Returns:
- the head element, or
nullif all sorted sets are empty
-
pollFirstFromAnyAsync
public RFuture<V> pollFirstFromAnyAsync(long timeout, TimeUnit unit, String... queueNames)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns first available head element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.Requires Redis 5.0.0 and higher.
- Specified by:
pollFirstFromAnyAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameterqueueNames- - names of queue- Returns:
- the head element, or
nullif all sorted sets are empty
-
pollLastFromAny
public V pollLastFromAny(long timeout, TimeUnit unit, String... queueNames)
Description copied from interface:RScoredSortedSetRemoves and returns first available tail element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.Requires Redis 5.0.0 and higher.
- Specified by:
pollLastFromAnyin interfaceRScoredSortedSet<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameterqueueNames- - names of queue- Returns:
- the tail element, or
nullif all sorted sets are empty
-
pollLastFromAnyAsync
public RFuture<V> pollLastFromAnyAsync(long timeout, TimeUnit unit, String... queueNames)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns first available tail element of any sorted set, waiting up to the specified wait time if necessary for an element to become available in any of defined sorted sets including this one.Requires Redis 5.0.0 and higher.
- Specified by:
pollLastFromAnyAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameterqueueNames- - names of queue- Returns:
- the tail element, or
nullif all sorted sets are empty
-
pollLast
public V pollLast(long timeout, TimeUnit unit)
Description copied from interface:RScoredSortedSetRemoves and returns the tail element ornullif this sorted set is empty.- Specified by:
pollLastin interfaceRScoredSortedSet<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameter- Returns:
- the tail element or
nullif this sorted set is empty
-
pollLastAsync
public RFuture<V> pollLastAsync(long timeout, TimeUnit unit)
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the tail element ornullif this sorted set is empty.Requires Redis 5.0.0 and higher.
- Specified by:
pollLastAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
timeout- how long to wait before giving up, in units ofunitunit- aTimeUnitdetermining how to interpret thetimeoutparameter- Returns:
- the tail element or
nullif this sorted set is empty
-
random
public V random()
Description copied from interface:RScoredSortedSetReturns random element from this sorted setRequires Redis 6.2.0 and higher.
- Specified by:
randomin interfaceRScoredSortedSet<V>- Returns:
- random element
-
random
public Collection<V> random(int count)
Description copied from interface:RScoredSortedSetReturns random elements from this sorted set limited bycountRequires Redis 6.2.0 and higher.
- Specified by:
randomin interfaceRScoredSortedSet<V>- Parameters:
count- - values amount to return- Returns:
- random elements
-
randomAsync
public RFuture<V> randomAsync()
Description copied from interface:RScoredSortedSetAsyncReturns random element from this sorted setRequires Redis 6.2.0 and higher.
- Specified by:
randomAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- value
-
randomAsync
public RFuture<Collection<V>> randomAsync(int count)
Description copied from interface:RScoredSortedSetAsyncReturns random elements from this sorted set limited bycountRequires Redis 6.2.0 and higher.
- Specified by:
randomAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
count- - values amount to return- Returns:
- value
-
randomEntries
public Map<V,Double> randomEntries(int count)
Description copied from interface:RScoredSortedSetReturns random entries from this sorted set limited bycount. Each map entry uses element as key and score as value.Requires Redis 6.2.0 and higher.
- Specified by:
randomEntriesin interfaceRScoredSortedSet<V>- Parameters:
count- - entries amount to return- Returns:
- random entries
-
randomEntriesAsync
public RFuture<Map<V,Double>> randomEntriesAsync(int count)
Description copied from interface:RScoredSortedSetAsyncReturns random entries from this sorted set limited bycount. Each map entry uses element as key and score as value.Requires Redis 6.2.0 and higher.
- Specified by:
randomEntriesAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
count- - entries amount to return- Returns:
- random entries
-
add
public boolean add(double score, V object)Description copied from interface:RScoredSortedSetAdds element to this set, overrides previous score if it has been already added.- Specified by:
addin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element has added andfalseif not.
-
addAndGetRank
public Integer addAndGetRank(double score, V object)
Description copied from interface:RScoredSortedSetAdds element to this set, overrides previous score if it has been already added. Finally return the rank of the item- Specified by:
addAndGetRankin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
- rank
-
addAndGetRankAsync
public RFuture<Integer> addAndGetRankAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set, overrides previous score if it has been already added. Finally return the rank of the item- Specified by:
addAndGetRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
- rank
-
addAndGetRevRank
public Integer addAndGetRevRank(double score, V object)
Description copied from interface:RScoredSortedSetAdds element to this set, overrides previous score if it has been already added. Finally return the reverse rank of the item- Specified by:
addAndGetRevRankin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
- reverse rank
-
addAndGetRevRank
public List<Integer> addAndGetRevRank(Map<? extends V,Double> map)
Description copied from interface:RScoredSortedSetAdds elements to this set, overrides previous score if it has been already added. Finally returns reverse rank list of the items- Specified by:
addAndGetRevRankin interfaceRScoredSortedSet<V>- Parameters:
map- - map of object and scores, make sure to use an ordered map- Returns:
- collection of reverse ranks
-
addAndGetRevRankAsync
public RFuture<Integer> addAndGetRevRankAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set, overrides previous score if it has been already added. Finally return the reverse rank of the item- Specified by:
addAndGetRevRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
- reverse rank
-
addAndGetRevRankAsync
public RFuture<List<Integer>> addAndGetRevRankAsync(Map<? extends V,Double> map)
Description copied from interface:RScoredSortedSetAsyncAdds elements to this set, overrides previous score if it has been already added. Finally returns reverse rank list of the items- Specified by:
addAndGetRevRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
map- - map of object and scores, make sure to use an ordered map- Returns:
- collection of reverse ranks
-
tryAdd
public boolean tryAdd(double score, V object)Description copied from interface:RScoredSortedSetAdds element to this set only if has not been added before.Requires Redis 3.0.2 and higher.
- Specified by:
tryAddin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfExists
public boolean addIfExists(double score, V object)Description copied from interface:RScoredSortedSetAdds element to this set only if it's already exists.Requires Redis 3.0.2 and higher.
- Specified by:
addIfExistsin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfExistsAsync
public RFuture<Boolean> addIfExistsAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set only if it's already exists.Requires Redis 3.0.2 and higher.
- Specified by:
addIfExistsAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfLess
public boolean addIfLess(double score, V object)Description copied from interface:RScoredSortedSetAdds element to this set only if new score less than current score of existed element.Requires Redis 6.2.0 and higher.
- Specified by:
addIfLessin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfGreater
public boolean addIfGreater(double score, V object)Description copied from interface:RScoredSortedSetAdds element to this set only if new score greater than current score of existed element.Requires Redis 6.2.0 and higher.
- Specified by:
addIfGreaterin interfaceRScoredSortedSet<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfLessAsync
public RFuture<Boolean> addIfLessAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set only if new score less than current score of existed element.Requires Redis 6.2.0 and higher.
- Specified by:
addIfLessAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
addIfGreaterAsync
public RFuture<Boolean> addIfGreaterAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set only if new score greater than current score of existed element.Requires Redis 6.2.0 and higher.
- Specified by:
addIfGreaterAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element added andfalseif not.
-
first
public V first()
Description copied from interface:RScoredSortedSetReturns the head element ornullif this sorted set is empty.- Specified by:
firstin interfaceRScoredSortedSet<V>- Returns:
- the head element or
nullif this sorted set is empty
-
firstAsync
public RFuture<V> firstAsync()
Description copied from interface:RScoredSortedSetAsyncReturns the head element ornullif this sorted set is empty.- Specified by:
firstAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the head element or
nullif this sorted set is empty
-
last
public V last()
Description copied from interface:RScoredSortedSetReturns the tail element ornullif this sorted set is empty.- Specified by:
lastin interfaceRScoredSortedSet<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
lastAsync
public RFuture<V> lastAsync()
Description copied from interface:RScoredSortedSetAsyncReturns the tail element ornullif this sorted set is empty.- Specified by:
lastAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
firstScore
public Double firstScore()
Description copied from interface:RScoredSortedSetReturns score of the tail element or returnsnullif this sorted set is empty.- Specified by:
firstScorein interfaceRScoredSortedSet<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
firstScoreAsync
public RFuture<Double> firstScoreAsync()
Description copied from interface:RScoredSortedSetAsyncReturns score of the head element or returnsnullif this sorted set is empty.- Specified by:
firstScoreAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
lastScore
public Double lastScore()
Description copied from interface:RScoredSortedSetReturns score of the head element or returnsnullif this sorted set is empty.- Specified by:
lastScorein interfaceRScoredSortedSet<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
lastScoreAsync
public RFuture<Double> lastScoreAsync()
Description copied from interface:RScoredSortedSetAsyncReturns score of the tail element or returnsnullif this sorted set is empty.- Specified by:
lastScoreAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the tail element or
nullif this sorted set is empty
-
addAsync
public RFuture<Boolean> addAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set, overrides previous score if it has been already added.- Specified by:
addAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element has added andfalseif not.
-
addAll
public int addAll(Map<V,Double> objects)
Description copied from interface:RScoredSortedSetAdds all elements contained in the specified map to this sorted set. Map contains of score mapped by object.- Specified by:
addAllin interfaceRScoredSortedSet<V>- Parameters:
objects- - map of elements to add- Returns:
- amount of added elements, not including already existing in this sorted set
-
addAllAsync
public RFuture<Integer> addAllAsync(Map<V,Double> objects)
Description copied from interface:RScoredSortedSetAsyncAdds all elements contained in the specified map to this sorted set. Map contains of score mapped by object.- Specified by:
addAllAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
objects- - map of elements to add- Returns:
- amount of added elements, not including already existing in this sorted set
-
tryAddAsync
public RFuture<Boolean> tryAddAsync(double score, V object)
Description copied from interface:RScoredSortedSetAsyncAdds element to this set only if has not been added before.Requires Redis 3.0.2 and higher.
- Specified by:
tryAddAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
score- - object scoreobject- - object itself- Returns:
trueif element has added andfalseif not.
-
remove
public boolean remove(Object object)
Description copied from interface:RScoredSortedSetRemoves a single instance of the specified element from this sorted set, if it is present.- Specified by:
removein interfaceRScoredSortedSet<V>- Parameters:
object- element to be removed from this sorted set, if present- Returns:
trueif an element was removed as a result of this call
-
removeRangeByRank
public int removeRangeByRank(int startIndex, int endIndex)Description copied from interface:RScoredSortedSetRemoves values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
removeRangeByRankin interfaceRScoredSortedSet<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- number of elements removed
-
removeRangeByRankAsync
public RFuture<Integer> removeRangeByRankAsync(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncRemoves values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
removeRangeByRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- number of elements removed
-
removeRangeByScore
public int removeRangeByScore(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Description copied from interface:RScoredSortedSetRemoves values by score range.- Specified by:
removeRangeByScorein interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- number of elements removed
-
removeRangeByScoreAsync
public RFuture<Integer> removeRangeByScoreAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncRemoves values by score range.- Specified by:
removeRangeByScoreAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- number of elements removed
-
clear
public void clear()
Description copied from interface:RScoredSortedSetRemoves all elements of this sorted set.- Specified by:
clearin interfaceRScoredSortedSet<V>
-
removeAsync
public RFuture<Boolean> removeAsync(Object object)
Description copied from interface:RScoredSortedSetAsyncRemoves a single instance of the specified element from this sorted set, if it is present.- Specified by:
removeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
object- element to be removed from this sorted set, if present- Returns:
trueif an element was removed as a result of this call
-
isEmpty
public boolean isEmpty()
Description copied from interface:RScoredSortedSetReturnstrueif this set is empty- Specified by:
isEmptyin interfaceRScoredSortedSet<V>- Returns:
trueif empty
-
size
public int size()
Description copied from interface:RScoredSortedSetReturns size of this set.- Specified by:
sizein interfaceRScoredSortedSet<V>- Returns:
- size
-
sizeAsync
public RFuture<Integer> sizeAsync()
Description copied from interface:RScoredSortedSetAsyncReturns size of this set.- Specified by:
sizeAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- size
-
contains
public boolean contains(Object object)
Description copied from interface:RScoredSortedSetReturnstrueif this sorted set contains encoded state of the specified element.- Specified by:
containsin interfaceRScoredSortedSet<V>- Parameters:
object- element whose presence in this collection is to be tested- Returns:
trueif this sorted set contains the specified element andfalseotherwise
-
containsAsync
public RFuture<Boolean> containsAsync(Object o)
Description copied from interface:RScoredSortedSetAsyncReturnstrueif this sorted set contains encoded state of the specified element.- Specified by:
containsAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
o- element whose presence in this collection is to be tested- Returns:
trueif this sorted set contains the specified element andfalseotherwise
-
getScore
public Double getScore(V o)
Description copied from interface:RScoredSortedSetReturns score of element ornullif it doesn't exist.- Specified by:
getScorein interfaceRScoredSortedSet<V>- Parameters:
o- - element- Returns:
- score
-
getScore
public List<Double> getScore(List<V> keys)
Description copied from interface:RScoredSortedSetReturns scores of elements.- Specified by:
getScorein interfaceRScoredSortedSet<V>- Parameters:
keys- - elements- Returns:
- element scores
-
getScoreAsync
public RFuture<Double> getScoreAsync(V o)
Description copied from interface:RScoredSortedSetAsyncReturns score of element ornullif it doesn't exist.- Specified by:
getScoreAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
o- - element- Returns:
- score
-
getScoreAsync
public RFuture<List<Double>> getScoreAsync(Collection<V> elements)
Description copied from interface:RScoredSortedSetAsyncReturns scores of elements.- Specified by:
getScoreAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
elements- - elements- Returns:
- element scores
-
rank
public Integer rank(V o)
Description copied from interface:RScoredSortedSetReturns rank of value, with the scores ordered from low to high.- Specified by:
rankin interfaceRScoredSortedSet<V>- Parameters:
o- - object- Returns:
- rank or
nullif value does not exist
-
rankAsync
public RFuture<Integer> rankAsync(V o)
Description copied from interface:RScoredSortedSetAsyncReturns rank of value, with the scores ordered from low to high.- Specified by:
rankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
o- - object- Returns:
- rank or
nullif value does not exist
-
scanIteratorAsync
public RFuture<ScanResult<Object>> scanIteratorAsync(RedisClient client, long startPos, String pattern, int count)
-
iterator
public Iterator<V> iterator(String pattern)
Description copied from interface:RScoredSortedSetReturns an iterator over elements in this set. Ifpatternis not null then only elements match this pattern are loaded.- Specified by:
iteratorin interfaceRScoredSortedSet<V>- Parameters:
pattern- - search pattern- Returns:
- iterator
-
iterator
public Iterator<V> iterator(int count)
Description copied from interface:RScoredSortedSetReturns an iterator over elements in this set. Elements are loaded in batch. Batch size is defined bycountparam.- Specified by:
iteratorin interfaceRScoredSortedSet<V>- Parameters:
count- - size of elements batch- Returns:
- iterator
-
iterator
public Iterator<V> iterator(String pattern, int count)
Description copied from interface:RScoredSortedSetReturns an iterator over elements in this set. Elements are loaded in batch. Batch size is defined bycountparam. If pattern is not null then only elements match this pattern are loaded.- Specified by:
iteratorin interfaceRScoredSortedSet<V>- Parameters:
pattern- - search patterncount- - size of elements batch- Returns:
- iterator
-
toArray
public Object[] toArray()
Description copied from interface:RScoredSortedSetReturns this sorted set in array of Object type.- Specified by:
toArrayin interfaceRScoredSortedSet<V>- Returns:
- array of values
-
toArray
public <T> T[] toArray(T[] a)
Description copied from interface:RScoredSortedSetReturns this sorted set in array of defined type.- Specified by:
toArrayin interfaceRScoredSortedSet<V>- Type Parameters:
T- type of element- Parameters:
a- - instance of array- Returns:
- array of values
-
containsAll
public boolean containsAll(Collection<?> c)
Description copied from interface:RScoredSortedSetReturnstrueif this sorted set contains all of the elements in encoded state in the specified collection.- Specified by:
containsAllin interfaceRScoredSortedSet<V>- Parameters:
c- collection to be checked for containment in this sorted set- Returns:
trueif this sorted set contains all of the elements in the specified collection
-
containsAllAsync
public RFuture<Boolean> containsAllAsync(Collection<?> c)
Description copied from interface:RScoredSortedSetAsyncReturnstrueif this sorted set contains all of the elements in encoded state in the specified collection.- Specified by:
containsAllAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
c- collection to be checked for containment in this sorted set- Returns:
trueif this sorted set contains all of the elements in the specified collection
-
removeAllAsync
public RFuture<Boolean> removeAllAsync(Collection<?> c)
Description copied from interface:RScoredSortedSetAsyncRemoves all of this sorted set's elements that are also contained in the specified collection.- Specified by:
removeAllAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
c- sorted set containing elements to be removed from this collection- Returns:
trueif this sorted set changed as a result of the call
-
removeAll
public boolean removeAll(Collection<?> c)
Description copied from interface:RScoredSortedSetRemoves all of this sorted set's elements that are also contained in the specified collection.- Specified by:
removeAllin interfaceRScoredSortedSet<V>- Parameters:
c- collection containing elements to be removed from this collection- Returns:
trueif this sorted set changed as a result of the call
-
retainAll
public boolean retainAll(Collection<?> c)
Description copied from interface:RScoredSortedSetRetains only the elements in this sorted set that are contained in the specified collection.- Specified by:
retainAllin interfaceRScoredSortedSet<V>- Parameters:
c- collection containing elements to be retained in this collection- Returns:
trueif this sorted set changed as a result of the call
-
retainAllAsync
public RFuture<Boolean> retainAllAsync(Collection<?> c)
Description copied from interface:RScoredSortedSetAsyncRetains only the elements in this sorted set that are contained in the specified collection.- Specified by:
retainAllAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
c- collection containing elements to be retained in this collection- Returns:
trueif this sorted set changed as a result of the call
-
addScore
public Double addScore(V object, Number value)
Description copied from interface:RScoredSortedSetIncreases score of specified element by value.- Specified by:
addScorein interfaceRScoredSortedSet<V>- Parameters:
object- - element whose score needs to be increasedvalue- - value- Returns:
- updated score of element
-
addScoreAsync
public RFuture<Double> addScoreAsync(V object, Number value)
Description copied from interface:RScoredSortedSetAsyncIncreases score of specified element by value.- Specified by:
addScoreAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
object- - element whose score needs to be increasedvalue- - value- Returns:
- updated score of element
-
addScoreAndGetRank
public Integer addScoreAndGetRank(V object, Number value)
Description copied from interface:RScoredSortedSetAdds score to element and returns its rank- Specified by:
addScoreAndGetRankin interfaceRScoredSortedSet<V>- Parameters:
object- - object itselfvalue- - object score- Returns:
- rank
-
addScoreAndGetRankAsync
public RFuture<Integer> addScoreAndGetRankAsync(V object, Number value)
Description copied from interface:RScoredSortedSetAsyncAdds score to element and returns its rank- Specified by:
addScoreAndGetRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
object- - object itselfvalue- - object score- Returns:
- rank
-
addScoreAndGetRevRank
public Integer addScoreAndGetRevRank(V object, Number value)
Description copied from interface:RScoredSortedSetAdds score to element and returns its reverse rank- Specified by:
addScoreAndGetRevRankin interfaceRScoredSortedSet<V>- Parameters:
object- - object itselfvalue- - object score- Returns:
- reverse rank
-
addScoreAndGetRevRankAsync
public RFuture<Integer> addScoreAndGetRevRankAsync(V object, Number value)
Description copied from interface:RScoredSortedSetAsyncAdds score to element and returns its reverse rank- Specified by:
addScoreAndGetRevRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
object- - object itselfvalue- - object score- Returns:
- reverse rank
-
valueRange
public Collection<V> valueRange(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetReturns values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
valueRangein interfaceRScoredSortedSet<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- elements
-
valueRangeAsync
public RFuture<Collection<V>> valueRangeAsync(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncReturns values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.Requires Redis 6.2.0 and higher.
- Specified by:
valueRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- elements
-
valueRangeReversed
public Collection<V> valueRangeReversed(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetReturns values by rank range in reverse order. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
valueRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- elements
-
valueRangeReversedAsync
public RFuture<Collection<V>> valueRangeReversedAsync(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncReturns values by rank range in reverse order. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
valueRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- elements
-
entryRange
public Collection<ScoredEntry<V>> entryRange(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetReturns entries (value and its score) by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
entryRangein interfaceRScoredSortedSet<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- entries
-
entryRangeAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeAsync(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncReturns entries (value and its score) by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
entryRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- entries
-
entryRangeReversed
public Collection<ScoredEntry<V>> entryRangeReversed(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetReturns entries (value and its score) by rank range in reverse order. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
entryRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- entries
-
entryRangeReversedAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeReversedAsync(int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncReturns entries (value and its score) by rank range in reverse order. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
entryRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startIndex- - start indexendIndex- - end index- Returns:
- entries
-
valueRange
public Collection<V> valueRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetReturns all values betweenstartScoreandendScore.- Specified by:
valueRangein interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
valueRangeAsync
public RFuture<Collection<V>> valueRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncReturns all values betweenstartScoreandendScore.- Specified by:
valueRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
valueRangeReversed
public Collection<V> valueRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetReturns all values betweenstartScoreandendScorein reversed order.- Specified by:
valueRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
valueRangeReversedAsync
public RFuture<Collection<V>> valueRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncReturns all values betweenstartScoreandendScorein reversed order.- Specified by:
valueRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
entryRange
public Collection<ScoredEntry<V>> entryRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetReturns all entries (value and its score) betweenstartScoreandendScore.- Specified by:
entryRangein interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- entries
-
entryRangeAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncReturns all entries (value and its score) betweenstartScoreandendScore.- Specified by:
entryRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- entries
-
valueRange
public Collection<V> valueRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetReturns all values betweenstartScoreandendScore.- Specified by:
valueRangein interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
valueRangeAsync
public RFuture<Collection<V>> valueRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncReturns all values betweenstartScoreandendScore.- Specified by:
valueRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
valueRangeReversed
public Collection<V> valueRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetReturns all values betweenstartScoreandendScorein reversed order.- Specified by:
valueRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
valueRangeReversedAsync
public RFuture<Collection<V>> valueRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncReturns all values betweenstartScoreandendScorein reversed order.- Specified by:
valueRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
entryRange
public Collection<ScoredEntry<V>> entryRange(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetReturns all entries (value and its score) betweenstartScoreandendScore.- Specified by:
entryRangein interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- entries
-
entryRangeReversed
public Collection<ScoredEntry<V>> entryRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetReturns all entries (value and its score) betweenstartScoreandendScorein reversed order.- Specified by:
entryRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- entries
-
entryRangeAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncReturns all entries (value and its score) betweenstartScoreandendScore.- Specified by:
entryRangeAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- entries
-
entryRangeReversed
public Collection<ScoredEntry<V>> entryRangeReversed(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetReturns all entries (value and its score) betweenstartScoreandendScorein reversed order.- Specified by:
entryRangeReversedin interfaceRScoredSortedSet<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- entries
-
entryRangeReversedAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncReturns all entries (value and its score) betweenstartScoreandendScorein reversed order.- Specified by:
entryRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- entries
-
entryRangeReversedAsync
public RFuture<Collection<ScoredEntry<V>>> entryRangeReversedAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncReturns all entries (value and its score) betweenstartScoreandendScorein reversed order.- Specified by:
entryRangeReversedAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- entries
-
revRankAsync
public RFuture<Integer> revRankAsync(V o)
Description copied from interface:RScoredSortedSetAsyncReturns rank of value, with the scores ordered from high to low.- Specified by:
revRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
o- - object- Returns:
- rank or
nullif value does not exist
-
revRank
public Integer revRank(V o)
Description copied from interface:RScoredSortedSetReturns rank of value, with the scores ordered from high to low.- Specified by:
revRankin interfaceRScoredSortedSet<V>- Parameters:
o- - object- Returns:
- rank or
nullif value does not exist
-
revRankAsync
public RFuture<List<Integer>> revRankAsync(Collection<V> elements)
Description copied from interface:RScoredSortedSetAsyncReturns ranks of elements, with the scores ordered from high to low.- Specified by:
revRankAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
elements- - elements- Returns:
- ranks or
nullif value does not exist
-
revRank
public List<Integer> revRank(Collection<V> elements)
Description copied from interface:RScoredSortedSetReturns ranks of elements, with the scores ordered from high to low.- Specified by:
revRankin interfaceRScoredSortedSet<V>- Parameters:
elements- - elements- Returns:
- ranks or
nullif value does not exist
-
count
public int count(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)Description copied from interface:RScoredSortedSetReturns the number of elements with a score betweenstartScoreandendScore.- Specified by:
countin interfaceRScoredSortedSet<V>- Parameters:
startScore- - start scorestartScoreInclusive- - start score inclusiveendScore- - end scoreendScoreInclusive- - end score inclusive- Returns:
- count of elements
-
countAsync
public RFuture<Integer> countAsync(double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncReturns the number of elements with a score betweenstartScoreandendScore.- Specified by:
countAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
startScore- - start scorestartScoreInclusive- - start score inclusiveendScore- - end scoreendScoreInclusive- - end score inclusive- Returns:
- count
-
intersection
public int intersection(String... names)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets and store result to current ScoredSortedSet- Specified by:
intersectionin interfaceRScoredSortedSet<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- length of intersection
-
intersectionAsync
public RFuture<Integer> intersectionAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets and store result to current ScoredSortedSet- Specified by:
intersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- length of intersection
-
intersection
public int intersection(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSet- Specified by:
intersectionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- length of intersection
-
intersectionAsync
public RFuture<Integer> intersectionAsync(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSet- Specified by:
intersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- length of intersection
-
intersection
public int intersection(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSet- Specified by:
intersectionin interfaceRScoredSortedSet<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of intersection
-
intersectionAsync
public RFuture<Integer> intersectionAsync(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSet- Specified by:
intersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of intersection
-
intersection
public int intersection(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSet- Specified by:
intersectionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of intersection
-
intersectionAsync
public RFuture<Integer> intersectionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSet- Specified by:
intersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of intersection
-
readIntersection
public Collection<V> readIntersection(String... names)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets with current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionin interfaceRScoredSortedSet<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- result of intersection
-
readIntersectionAsync
public RFuture<Collection<V>> readIntersectionAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets with current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- result of intersection
-
readIntersection
public Collection<V> readIntersection(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- result of intersection
-
readIntersectionAsync
public RFuture<Collection<V>> readIntersectionAsync(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets with current ScoredSortedSet using defined aggregation method without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- result of intersection
-
readIntersection
public Collection<V> readIntersection(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionin interfaceRScoredSortedSet<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of intersection
-
readIntersectionAsync
public RFuture<Collection<V>> readIntersectionAsync(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of intersection
-
readIntersection
public Collection<V> readIntersection(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetIntersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet using defined aggregation method without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of intersection
-
readIntersectionAsync
public RFuture<Collection<V>> readIntersectionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncIntersect provided ScoredSortedSets mapped to weight multiplier with current ScoredSortedSet using defined aggregation method without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readIntersectionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of intersection
-
union
public int union(String... names)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets and store result to current ScoredSortedSet- Specified by:
unionin interfaceRScoredSortedSet<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- length of union
-
unionAsync
public RFuture<Integer> unionAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets and store result to current ScoredSortedSet- Specified by:
unionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- length of union
-
union
public int union(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSet- Specified by:
unionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- length of union
-
unionAsync
public RFuture<Integer> unionAsync(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets with defined aggregation method and store result to current ScoredSortedSet- Specified by:
unionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- length of union
-
union
public int union(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSet- Specified by:
unionin interfaceRScoredSortedSet<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of union
-
unionAsync
public RFuture<Integer> unionAsync(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets mapped to weight multiplier and store result to current ScoredSortedSet- Specified by:
unionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of union
-
union
public int union(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSet- Specified by:
unionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of union
-
unionAsync
public RFuture<Integer> unionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and store result to current ScoredSortedSet- Specified by:
unionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- length of union
-
readUnion
public Collection<V> readUnion(String... names)
Description copied from interface:RScoredSortedSetUnion ScoredSortedSets specified by name with current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionin interfaceRScoredSortedSet<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- result of union
-
readUnionAsync
public RFuture<Collection<V>> readUnionAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncUnion ScoredSortedSets specified by name with current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - names of ScoredSortedSet- Returns:
- result of union
-
readUnion
public Collection<V> readUnion(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetUnion ScoredSortedSets specified by name with defined aggregation method and current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- result of union
-
readUnionAsync
public RFuture<Collection<V>> readUnionAsync(RScoredSortedSet.Aggregate aggregate, String... names)
Description copied from interface:RScoredSortedSetAsyncUnion ScoredSortedSets specified by name with defined aggregation method and current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenames- - names of ScoredSortedSet- Returns:
- result of union
-
readUnion
public Collection<V> readUnion(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets mapped to weight multiplier and current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionin interfaceRScoredSortedSet<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of union
-
readUnionAsync
public RFuture<Collection<V>> readUnionAsync(Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets mapped to weight multiplier and current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readUnionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
nameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of union
-
readUnion
public Collection<V> readUnion(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetUnion provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readUnionin interfaceRScoredSortedSet<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of union
-
readUnionAsync
public RFuture<Collection<V>> readUnionAsync(RScoredSortedSet.Aggregate aggregate, Map<String,Double> nameWithWeight)
Description copied from interface:RScoredSortedSetAsyncUnion provided ScoredSortedSets mapped to weight multiplier with defined aggregation method and current ScoredSortedSet without state changeRequires Redis 6.2.0 and higher.
- Specified by:
readUnionAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
aggregate- - score aggregation modenameWithWeight- - name of ScoredSortedSet mapped to weight multiplier- Returns:
- result of union
-
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
-
readDiff
public Collection<V> readDiff(String... names)
Description copied from interface:RScoredSortedSetDiff ScoredSortedSets specified by name with current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readDiffin interfaceRScoredSortedSet<V>- Parameters:
names- - name of sets- Returns:
- result of diff
-
readDiffAsync
public RFuture<Collection<V>> readDiffAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncDiff ScoredSortedSets specified by name with current ScoredSortedSet without state change.Requires Redis 6.2.0 and higher.
- Specified by:
readDiffAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - name of sets- Returns:
- result of diff
-
diff
public int diff(String... names)
Description copied from interface:RScoredSortedSetDiff provided ScoredSortedSets and store result to current ScoredSortedSetRequires Redis 6.2.0 and higher.
- Specified by:
diffin interfaceRScoredSortedSet<V>- Parameters:
names- - name of sets- Returns:
- length of diff
-
diffAsync
public RFuture<Integer> diffAsync(String... names)
Description copied from interface:RScoredSortedSetAsyncDiff provided ScoredSortedSets and store result to current ScoredSortedSetRequires Redis 6.2.0 and higher.
- Specified by:
diffAsyncin interfaceRScoredSortedSetAsync<V>- Parameters:
names- - name of sets- Returns:
- length of diff
-
rangeTo
public int rangeTo(String destName, int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.Requires Redis 6.2.0 and higher.
- Specified by:
rangeToin interfaceRScoredSortedSet<V>startIndex- - start indexendIndex- - end index- Returns:
- elements
-
rangeTo
public int rangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
rangeToin interfaceRScoredSortedSet<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
rangeTo
public int rangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
rangeToin interfaceRScoredSortedSet<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
revRangeTo
public int revRangeTo(String destName, int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values in reversed order by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.Requires Redis 6.2.0 and higher.
- Specified by:
revRangeToin interfaceRScoredSortedSet<V>startIndex- - start indexendIndex- - end index- Returns:
- elements
-
revRangeTo
public int revRangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
revRangeToin interfaceRScoredSortedSet<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
revRangeTo
public int revRangeTo(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetStores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
revRangeToin interfaceRScoredSortedSet<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
revRangeToAsync
public RFuture<Integer> revRangeToAsync(String destName, int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values in reversed order by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
revRangeToAsyncin interfaceRScoredSortedSetAsync<V>startIndex- - start indexendIndex- - end index- Returns:
- elements
-
revRangeToAsync
public RFuture<Integer> revRangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
revRangeToAsyncin interfaceRScoredSortedSetAsync<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
revRangeToAsync
public RFuture<Integer> revRangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values in reversed order betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
revRangeToAsyncin interfaceRScoredSortedSetAsync<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
rangeToAsync
public RFuture<Integer> rangeToAsync(String destName, int startIndex, int endIndex)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values by rank range. Indexes are zero based.-1means the highest score,-2means the second highest score.- Specified by:
rangeToAsyncin interfaceRScoredSortedSetAsync<V>startIndex- - start indexendIndex- - end index- Returns:
- elements
-
rangeToAsync
public RFuture<Integer> rangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
rangeToAsyncin interfaceRScoredSortedSetAsync<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusive- Returns:
- values
-
rangeToAsync
public RFuture<Integer> rangeToAsync(String destName, double startScore, boolean startScoreInclusive, double endScore, boolean endScoreInclusive, int offset, int count)
Description copied from interface:RScoredSortedSetAsyncStores to defined ScoredSortedSet values betweenstartScoreandendScore.Requires Redis 6.2.0 and higher.
- Specified by:
rangeToAsyncin interfaceRScoredSortedSetAsync<V>startScore- - start score. UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersstartScoreInclusive- - start score inclusiveendScore- - end score UseDouble.POSITIVE_INFINITYorDouble.NEGATIVE_INFINITYto define infinity numbersendScoreInclusive- - end score inclusiveoffset- - offset of sorted datacount- - amount of sorted data- Returns:
- values
-
takeFirstAsync
public RFuture<V> takeFirstAsync()
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the head element waiting if necessary for an element to become available.- Specified by:
takeFirstAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the head element
-
takeLastAsync
public RFuture<V> takeLastAsync()
Description copied from interface:RScoredSortedSetAsyncRemoves and returns the tail element waiting if necessary for an element to become available.- Specified by:
takeLastAsyncin interfaceRScoredSortedSetAsync<V>- Returns:
- the tail element
-
takeFirst
public V takeFirst()
Description copied from interface:RScoredSortedSetRemoves and returns the head element waiting if necessary for an element to become available.- Specified by:
takeFirstin interfaceRScoredSortedSet<V>- Returns:
- the head element
-
takeLast
public V takeLast()
Description copied from interface:RScoredSortedSetRemoves and returns the tail element waiting if necessary for an element to become available.- Specified by:
takeLastin interfaceRScoredSortedSet<V>- Returns:
- the tail element
-
subscribeOnFirstElements
public int subscribeOnFirstElements(Consumer<V> consumer)
Description copied from interface:RScoredSortedSetSubscribes on first elements appeared in this set. Continuously invokesRScoredSortedSetAsync.takeFirstAsync()method to get a new element.- Specified by:
subscribeOnFirstElementsin interfaceRScoredSortedSet<V>- Parameters:
consumer- - queue elements listener- Returns:
- listenerId - id of listener
-
subscribeOnLastElements
public int subscribeOnLastElements(Consumer<V> consumer)
Description copied from interface:RScoredSortedSetSubscribes on last elements appeared in this set. Continuously invokesRScoredSortedSetAsync.takeLastAsync()method to get a new element.- Specified by:
subscribeOnLastElementsin interfaceRScoredSortedSet<V>- Parameters:
consumer- - queue elements listener- Returns:
- listenerId - id of listener
-
unsubscribe
public void unsubscribe(int listenerId)
Description copied from interface:RScoredSortedSetUn-subscribes defined listener.- Specified by:
unsubscribein interfaceRScoredSortedSet<V>- Parameters:
listenerId- - id of listener
-
stream
public Stream<V> stream()
Description copied from interface:RScoredSortedSetReturns stream of elements in this set. Elements are loaded in batch. Batch size is 10.- Specified by:
streamin interfaceRScoredSortedSet<V>- Returns:
- stream of elements
-
stream
public Stream<V> stream(String pattern)
Description copied from interface:RScoredSortedSetReturns stream of elements in this set. Ifpatternis not null then only elements match this pattern are loaded.- Specified by:
streamin interfaceRScoredSortedSet<V>- Parameters:
pattern- - search pattern- Returns:
- stream of elements
-
stream
public Stream<V> stream(int count)
Description copied from interface:RScoredSortedSetReturns stream of elements in this set. Elements are loaded in batch. Batch size is defined bycountparam.- Specified by:
streamin interfaceRScoredSortedSet<V>- Parameters:
count- - size of elements batch- Returns:
- stream of elements
-
stream
public Stream<V> stream(String pattern, int count)
Description copied from interface:RScoredSortedSetReturns stream of elements in this set. Elements are loaded in batch. Batch size is defined bycountparam. If pattern is not null then only elements match this pattern are loaded.- Specified by:
streamin interfaceRScoredSortedSet<V>- Parameters:
pattern- - search patterncount- - size of elements batch- Returns:
- stream of elements
-
addListener
public int addListener(ObjectListener listener)
Description copied from interface:RObjectAdds object event listener- Specified by:
addListenerin interfaceRObject- Overrides:
addListenerin classRedissonObject- Parameters:
listener- - object event listener- Returns:
- listener id
- See Also:
ExpiredObjectListener,DeletedObjectListener
-
addListenerAsync
public RFuture<Integer> addListenerAsync(ObjectListener listener)
Description copied from interface:RObjectAsyncAdds object event listener- Specified by:
addListenerAsyncin interfaceRObjectAsync- Overrides:
addListenerAsyncin classRedissonObject- Parameters:
listener- - object event listener- Returns:
- listener id
- See Also:
ExpiredObjectListener,DeletedObjectListener
-
removeListener
public void removeListener(int listenerId)
Description copied from interface:RObjectRemoves object event listener- Specified by:
removeListenerin interfaceRObject- Overrides:
removeListenerin classRedissonObject- Parameters:
listenerId- - listener id
-
removeListenerAsync
public RFuture<Void> removeListenerAsync(int listenerId)
Description copied from interface:RObjectAsyncRemoves object event listener- Specified by:
removeListenerAsyncin interfaceRObjectAsync- Overrides:
removeListenerAsyncin classRedissonObject- Parameters:
listenerId- - listener id
-
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)
-
-