Uses of Class
org.springframework.data.redis.connection.ReactiveZSetCommands.ZAggregateCommand
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveZSetCommands.ZAggregateCommand in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionReactiveZSetCommands.ZAggregateCommand.aggregateUsing
(Aggregate aggregateFunction) Applies a specificAggregate
function.ReactiveZSetCommands.ZAggregateCommand.applyWeights
(List<Double> weights) Applies theList
of weights.ReactiveZSetCommands.ZAggregateCommand.applyWeights
(Weights weights) Applies theWeights
.ReactiveZSetCommands.ZAggregateCommand.sets
(List<ByteBuffer> keys) Creates a newReactiveZSetCommands.ZAggregateCommand
given aList
of keys.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zInter
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zInterWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zUnion
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zUnionWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zInter
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zInterWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<ByteBuffer>>> ReactiveZSetCommands.zUnion
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,
reactor.core.publisher.Flux<Tuple>>> ReactiveZSetCommands.zUnionWithScores
(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands) Union sorted sets by applying aggregateFunction and apply weights to individual sets.