org.springframework.data.redis.connection.lettuce

Class LettuceReactiveClusterHyperLogLogCommands

java.lang.Object

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

org.springframework.data.redis.connection.lettuce.LettuceReactiveClusterHyperLogLogCommands

All Implemented Interfaces:

ReactiveClusterHyperLogLogCommands, ReactiveHyperLogLogCommands

public class LettuceReactiveClusterHyperLogLogCommands
extends LettuceReactiveHyperLogLogCommands
implements ReactiveClusterHyperLogLogCommands

Since:

@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
LettuceReactiveClusterHyperLogLogCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveHyperLogLogCommands.

Method Summary

Modifier and Type	Method and Description
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 org.springframework.data.redis.connection.lettuce.LettuceReactiveHyperLogLogCommands

getConnection, pfAdd

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, pfAdd, pfCount, pfCount, pfMerge

Constructor Detail

LettuceReactiveClusterHyperLogLogCommands

public LettuceReactiveClusterHyperLogLogCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveHyperLogLogCommands.

Parameters:

connection - must not be null.

Method Detail

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

Overrides:

pfMerge in class LettuceReactiveHyperLogLogCommands

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

Overrides:

pfCount in class LettuceReactiveHyperLogLogCommands

Parameters:

commands - must not be null.

Returns: