Package org.redisson.api
Interface RHyperLogLogReactive<V>
-
- Type Parameters:
V- type of stored values
- All Superinterfaces:
RExpirableReactive,RObjectReactive
public interface RHyperLogLogReactive<V> extends RExpirableReactive
Probabilistic data structure that lets you maintain counts of millions of items with extreme space efficiency. Reactive interface.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description reactor.core.publisher.Mono<Boolean>add(V obj)Adds element into this structure.reactor.core.publisher.Mono<Boolean>addAll(Collection<V> objects)Adds all elements contained inobjectscollection into this structurereactor.core.publisher.Mono<Long>count()Returns approximated number of unique elements added into this structure.reactor.core.publisher.Mono<Long>countWith(String... otherLogNames)Returns approximated number of unique elements added into this instances and other instances defined throughotherLogNames.reactor.core.publisher.Mono<Void>mergeWith(String... otherLogNames)Merges multiple instances into this instance.-
Methods inherited from interface org.redisson.api.RExpirableReactive
clearExpire, expire, expireAt, expireAt, expireAt, remainTimeToLive
-
Methods inherited from interface org.redisson.api.RObjectReactive
addListener, copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink
-
-
-
-
Method Detail
-
add
reactor.core.publisher.Mono<Boolean> add(V obj)
Adds element into this structure.- Parameters:
obj- - element to add- Returns:
trueif object has been added orfalseif it was already added
-
addAll
reactor.core.publisher.Mono<Boolean> addAll(Collection<V> objects)
Adds all elements contained inobjectscollection into this structure- Parameters:
objects- - elements to add- Returns:
trueif at least one object has been added orfalseif all were already added
-
count
reactor.core.publisher.Mono<Long> count()
Returns approximated number of unique elements added into this structure.- Returns:
- approximated number of unique elements added into this structure
-
countWith
reactor.core.publisher.Mono<Long> countWith(String... otherLogNames)
Returns approximated number of unique elements added into this instances and other instances defined throughotherLogNames.- Parameters:
otherLogNames- - name of instances- Returns:
- number
-
-