Class RedissonTransactionalSet<V>

  • Type Parameters:
    V - value type
    All Implemented Interfaces:
    <V>, <V>, <V>, <V>>, <V>>, ScanIterator

    public class RedissonTransactionalSet<V>
    extends RedissonSet<V>
    Author:
    Nikita Koksharov
    • Method Detail

      • expireAsync

        public > expireAsync​(long timeToLive,
                                             timeUnit)
        Description copied from interface: RExpirableAsync
        Set a timeout for object in async mode. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • expireAsync

        public > expireAsync​( timestamp)
        Description copied from interface: RExpirableAsync
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expireAsync in interface RExpirableAsync
        Parameters:
        timestamp - - expire date
        Returns:
        true if the timeout was set and false if not
      • clearExpireAsync

        public > clearExpireAsync()
        Description copied from interface: RExpirableAsync
        Clear an expire timeout or expire date for object in async mode. Object will not be deleted.
        Specified by:
        clearExpireAsync in interface RExpirableAsync
        Returns:
        true if the timeout was cleared and false if not
      • moveAsync

        public > moveAsync​(int database)
        Description copied from interface: RObjectAsync
        Move object to another database in async mode
        Specified by:
        moveAsync in interface RObjectAsync
        Overrides:
        moveAsync in class RedissonObject
        Parameters:
        database - - number of Redis database
        Returns:
        true if key was moved false if not
      • migrateAsync

        public > migrateAsync​( host,
                                          int port,
                                          int database,
                                          long timeout)
        Description copied from interface: RObjectAsync
        Transfer object from source Redis instance to destination Redis instance in async mode
        Specified by:
        migrateAsync in interface RObjectAsync
        Overrides:
        migrateAsync in class RedissonObject
        Parameters:
        host - - destination host
        port - - destination port
        database - - destination database
        timeout - - maximum idle time in any moment of the communication with the destination instance in milliseconds
        Returns:
        void
      • mapReduce

        public <KOut,​VOut> RCollectionMapReduce<V,​KOut,​VOut> mapReduce()
        Description copied from interface: RSet
        Returns RMapReduce object associated with this object
        Specified by:
        mapReduce in interface RSet<V>
        Overrides:
        mapReduce in class RedissonSet<V>
        Type Parameters:
        KOut - output key
        VOut - output value
        Returns:
        MapReduce instance
      • getFairLock

        public RLock getFairLock​(V value)
        Description copied from interface: RSet
        Returns RLock instance associated with value
        Specified by:
        getFairLock in interface RSet<V>
        Overrides:
        getFairLock in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RLock object
      • getSemaphore

        public RSemaphore getSemaphore​(V value)
        Description copied from interface: RSet
        Returns RSemaphore instance associated with value
        Specified by:
        getSemaphore in interface RSet<V>
        Overrides:
        getSemaphore in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RSemaphore object
      • getLock

        public RLock getLock​(V value)
        Description copied from interface: RSet
        Returns lock instance associated with value
        Specified by:
        getLock in interface RSet<V>
        Overrides:
        getLock in class RedissonSet<V>
        Parameters:
        value - - set value
        Returns:
        RLock object
      • containsAsync

        public > containsAsync​( o)
        Description copied from interface: RCollectionAsync
        Returns true if this collection contains encoded state of the specified element.
        Specified by:
        containsAsync in interface RCollectionAsync<V>
        Overrides:
        containsAsync in class RedissonSet<V>
        Parameters:
        o - element whose presence in this collection is to be tested
        Returns:
        true if this collection contains the specified element and false otherwise
      • addAsync

        public > addAsync​(V e)
        Description copied from interface: RCollectionAsync
        Adds element into this collection.
        Specified by:
        addAsync in interface RCollectionAsync<V>
        Overrides:
        addAsync in class RedissonSet<V>
        Parameters:
        e - - element to add
        Returns:
        true if an element was added and false if it is already present
      • removeRandomAsync

        public <V>> removeRandomAsync​(int amount)
        Description copied from interface: RSetAsync
        Removes and returns random elements from set in async mode
        Specified by:
        removeRandomAsync in interface RSetAsync<V>
        Overrides:
        removeRandomAsync in class RedissonSet<V>
        Parameters:
        amount - of random values
        Returns:
        random values
      • removeAsync

        public > removeAsync​( o)
        Description copied from interface: RCollectionAsync
        Removes a single instance of the specified element from this collection, if it is present.
        Specified by:
        removeAsync in interface RCollectionAsync<V>
        Overrides:
        removeAsync in class RedissonSet<V>
        Parameters:
        o - element to be removed from this collection, if present
        Returns:
        true if an element was removed as a result of this call
      • moveAsync

        public > moveAsync​( destination,
                                          V member)
        Description copied from interface: RSetAsync
        Move a member from this set to the given destination set in async mode.
        Specified by:
        moveAsync in interface RSetAsync<V>
        Overrides:
        moveAsync in class RedissonSet<V>
        Parameters:
        destination - the destination set
        member - the member to move
        Returns:
        true if the element is moved, false if the element is not a member of this set or no operation was performed
      • addAllAsync

        public > addAllAsync​(<? extends V> c)
        Description copied from interface: RCollectionAsync
        Adds all elements contained in the specified collection
        Specified by:
        addAllAsync in interface RCollectionAsync<V>
        Overrides:
        addAllAsync in class RedissonSet<V>
        Parameters:
        c - - collection of elements to add
        Returns:
        true if at least one element was added and false if all elements are already present
      • retainAllAsync

        public > retainAllAsync​(<?> c)
        Description copied from interface: RCollectionAsync
        Retains only the elements in this collection that are contained in the specified collection.
        Specified by:
        retainAllAsync in interface RCollectionAsync<V>
        Overrides:
        retainAllAsync in class RedissonSet<V>
        Parameters:
        c - collection containing elements to be retained in this collection
        Returns:
        true if this collection changed as a result of the call
      • removeAllAsync

        public > removeAllAsync​(<?> c)
        Description copied from interface: RCollectionAsync
        Removes all of this collection's elements that are also contained in the specified collection.
        Specified by:
        removeAllAsync in interface RCollectionAsync<V>
        Overrides:
        removeAllAsync in class RedissonSet<V>
        Parameters:
        c - collection containing elements to be removed from this collection
        Returns:
        true if this collection changed as a result of the call
      • unionAsync

        public > unionAsync​(... names)
        Description copied from interface: RSetAsync
        Union sets specified by name and write to current set. If current set already exists, it is overwritten.
        Specified by:
        unionAsync in interface RSetAsync<V>
        Overrides:
        unionAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        size of union
      • diffAsync

        public > diffAsync​(... names)
        Description copied from interface: RSetAsync
        Diff sets specified by name and write to current set. If current set already exists, it is overwritten.
        Specified by:
        diffAsync in interface RSetAsync<V>
        Overrides:
        diffAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        size of diff
      • intersectionAsync

        public > intersectionAsync​(... names)
        Description copied from interface: RSetAsync
        Intersection sets specified by name and write to current set. If current set already exists, it is overwritten.
        Specified by:
        intersectionAsync in interface RSetAsync<V>
        Overrides:
        intersectionAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        size of intersection
      • readSortAsync

        public <V>> readSortAsync​(SortOrder order,
                                             int offset,
                                             int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view
        Specified by:
        readSortAsync in interface RSortableAsync<V>
        Overrides:
        readSortAsync in class RedissonSet<V>
        Parameters:
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection
      • readSortAsync

        public <T> <T>> readSortAsync​( byPattern,
                                                        <> getPatterns,
                                                        SortOrder order,
                                                        int offset,
                                                        int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view
        Specified by:
        readSortAsync in interface RSortableAsync<V>
        Overrides:
        readSortAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection
      • readSortAlphaAsync

        public <V>> readSortAlphaAsync​(SortOrder order,
                                                  int offset,
                                                  int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Parameters:
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection lexicographically
      • readSortAlphaAsync

        public < byPattern,
                                                  SortOrder order,
                                                  int offset,
                                                  int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection lexicographically
      • readSortAlphaAsync

        public <T> <T>> readSortAlphaAsync​( byPattern,
                                                             <> getPatterns,
                                                             SortOrder order)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        Returns:
        sorted collection lexicographically
      • readSortAlphaAsync

        public <T> <T>> readSortAlphaAsync​( byPattern,
                                                             <> getPatterns,
                                                             SortOrder order,
                                                             int offset,
                                                             int count)
        Description copied from interface: RSortableAsync
        Read data in sorted view lexicographically
        Specified by:
        readSortAlphaAsync in interface RSortableAsync<V>
        Overrides:
        readSortAlphaAsync in class RedissonSet<V>
        Type Parameters:
        T - object type
        Parameters:
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        sorted collection lexicographically
      • sortToAsync

        public > sortToAsync​( destName,
                                             byPattern,
                                            <> getPatterns,
                                            SortOrder order,
                                            int offset,
                                            int count)
        Description copied from interface: RSortableAsync
        Sort data and store to destName list
        Specified by:
        sortToAsync in interface RSortableAsync<V>
        Overrides:
        sortToAsync in class RedissonSet<V>
        Parameters:
        destName - list object destination
        byPattern - that is used to generate the keys that are used for sorting
        getPatterns - that is used to load values by keys in sorted view
        order - for sorted data
        offset - of sorted data
        count - of sorted data
        Returns:
        length of sorted data
      • readUnionAsync

        public <... names)
        Description copied from interface: RSetAsync
        Union sets specified by name with current set. Without current set state change.
        Specified by:
        readUnionAsync in interface RSetAsync<V>
        Overrides:
        readUnionAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        values
      • readDiffAsync

        public <... names)
        Description copied from interface: RSetAsync
        Diff sets specified by name with current set. Without current set state change.
        Specified by:
        readDiffAsync in interface RSetAsync<V>
        Overrides:
        readDiffAsync in class RedissonSet<V>
        Parameters:
        names - - name of sets
        Returns:
        values
      • checkState

        protected void checkState()
      • expire

        public boolean expire​(long timeToLive,
                               timeUnit)
        Description copied from interface: RExpirable
        Set a timeout for object. After the timeout has expired, the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        timeToLive - - timeout before object will be deleted
        timeUnit - - timeout time unit
        Returns:
        true if the timeout was set and false if not
      • expireAt

        public boolean expireAt​(long timestamp)
        Description copied from interface: RExpirable
        Specified by:
        expireAt in interface RExpirable
        Parameters:
        timestamp - - expire date in milliseconds (Unix timestamp)
        Returns:
        true if the timeout was set and false if not
      • expire

        public boolean expire​( instant)
        Description copied from interface: RExpirable
        Set an expire date for object. When expire date comes the key will automatically be deleted.
        Specified by:
        expire in interface RExpirable
        Parameters:
        instant - - expire date
        Returns:
        true if the timeout was set and false if not
      • expireAt

        public boolean expireAt​( timestamp)
        Description copied from interface: RExpirable
        Specified by:
        expireAt in interface RExpirable
        Parameters:
        timestamp - - expire date
        Returns:
        true if the timeout was set and false if not
      • clearExpire

        public boolean clearExpire()
        Description copied from interface: RExpirable
        Clear an expire timeout or expire date for object.
        Specified by:
        clearExpire in interface RExpirable
        Returns:
        true if timeout was removed false if object does not exist or does not have an associated timeout
      • remainTimeToLive

        public long remainTimeToLive()
        Description copied from interface: RExpirable
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLive in interface RExpirable
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
      • remainTimeToLiveAsync

        public > remainTimeToLiveAsync()
        Description copied from interface: RExpirableAsync
        Remaining time to live of Redisson object that has a timeout
        Specified by:
        remainTimeToLiveAsync in interface RExpirableAsync
        Returns:
        time in milliseconds -2 if the key does not exist. -1 if the key exists but has no associated expire.
      • expireAsync

        protected > expireAsync​(long timeToLive,
                                                timeUnit,
                                               ... keys)
      • expireAtAsync

        protected > expireAtAsync​(long timestamp,
                                                 ... keys)
      • clearExpireAsync

        protected > clearExpireAsync​(... keys)