org.springframework.data.redis.connection.lettuce

Class LettuceReactiveClusterZSetCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveZSetCommands

org.springframework.data.redis.connection.lettuce.LettuceReactiveClusterZSetCommands

All Implemented Interfaces:

ReactiveClusterZSetCommands, ReactiveZSetCommands

public class LettuceReactiveClusterZSetCommands
extends LettuceReactiveZSetCommands
implements ReactiveClusterZSetCommands

Since:

@since 2.0

Author:

Christoph Strobl

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveZSetCommands

ReactiveZSetCommands.ZAddCommand, ReactiveZSetCommands.ZCountCommand, ReactiveZSetCommands.ZIncrByCommand, ReactiveZSetCommands.ZInterStoreCommand, ReactiveZSetCommands.ZRangeByLexCommand, ReactiveZSetCommands.ZRangeByScoreCommand, ReactiveZSetCommands.ZRangeCommand, ReactiveZSetCommands.ZRankCommand, ReactiveZSetCommands.ZRemCommand, ReactiveZSetCommands.ZRemRangeByRankCommand, ReactiveZSetCommands.ZRemRangeByScoreCommand, ReactiveZSetCommands.ZScoreCommand, ReactiveZSetCommands.ZUnionStoreCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveClusterZSetCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveSetCommands.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>>	zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>>	zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Methods inherited from class org.springframework.data.redis.connection.lettuce.LettuceReactiveZSetCommands

getConnection, zAdd, zCard, zCount, zIncrBy, zRange, zRangeByLex, zRangeByScore, zRank, zRem, zRemRangeByRank, zRemRangeByScore, zScore

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveZSetCommands

zAdd, zAdd, zCard, zCard, zCount, zCount, zIncrBy, zIncrBy, zInterStore, zInterStore, zInterStore, zRange, zRange, zRangeByLex, zRangeByLex, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeWithScores, zRank, zRank, zRem, zRem, zRem, zRemRangeByRank, zRemRangeByRank, zRemRangeByScore, zRemRangeByScore, zRevRange, zRevRangeByLex, zRevRangeByLex, zRevRangeByScore, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeWithScores, zRevRank, zScore, zScore, zUnionStore, zUnionStore, zUnionStore

Constructor Detail

LettuceReactiveClusterZSetCommands

public LettuceReactiveClusterZSetCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveSetCommands.

Parameters:

connection - must not be null.

Method Detail

zUnionStore

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>> zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands)

Description copied from interface: ReactiveZSetCommands

Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Specified by:

zUnionStore in interface ReactiveZSetCommands

Overrides:

zUnionStore in class LettuceReactiveZSetCommands

Returns:

zInterStore

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>> zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands)

Description copied from interface: ReactiveZSetCommands

Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Specified by:

zInterStore in interface ReactiveZSetCommands

Overrides:

zInterStore in class LettuceReactiveZSetCommands

Returns: