org.springframework.data.redis.connection.lettuce

Class LettuceReactiveHyperLogLogCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveHyperLogLogCommands

All Implemented Interfaces:

ReactiveHyperLogLogCommands

Direct Known Subclasses:

LettuceReactiveClusterHyperLogLogCommands

public class LettuceReactiveHyperLogLogCommands
extends Object
implements ReactiveHyperLogLogCommands

Since:

2.0

Author:

Christoph Strobl

Nested Class Summary

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

ReactiveHyperLogLogCommands.PfAddCommand, ReactiveHyperLogLogCommands.PfCountCommand, ReactiveHyperLogLogCommands.PfMergeCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveHyperLogLogCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveHyperLogLogCommands.

Method Summary

Modifier and Type	Method and Description
protected LettuceReactiveRedisConnection	getConnection()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>>	pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands) Adds given values to the HyperLogLog stored at given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands) Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHyperLogLogCommands.PfMergeCommand>>	pfMerge(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfMergeCommand> commands) Merge N different HyperLogLogs at sourceKeys into a single destinationKey.

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.ReactiveHyperLogLogCommands

pfAdd, pfAdd, pfCount, pfCount, pfMerge

Constructor Detail

LettuceReactiveHyperLogLogCommands

public LettuceReactiveHyperLogLogCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveHyperLogLogCommands.

Parameters:

connection - must not be null.

Method Detail

pfAdd

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>> pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands)

Description copied from interface: ReactiveHyperLogLogCommands

Adds given values to the HyperLogLog stored at given key.

Specified by:

pfAdd in interface ReactiveHyperLogLogCommands

Parameters:

commands - must not be null.

Returns:

pfCount

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>> pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)

Description copied from interface: ReactiveHyperLogLogCommands

Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).

Specified by:

pfCount in interface ReactiveHyperLogLogCommands

Parameters:

commands - must not be null.

Returns:

pfMerge

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHyperLogLogCommands.PfMergeCommand>> pfMerge(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfMergeCommand> commands)

Description copied from interface: ReactiveHyperLogLogCommands

Merge N different HyperLogLogs at sourceKeys into a single destinationKey.

Specified by:

pfMerge in interface ReactiveHyperLogLogCommands

Parameters:

commands - must not be null.

Returns:

getConnection

protected LettuceReactiveRedisConnection getConnection()