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 Detail

      • add

        reactor.core.publisher.Mono<Boolean> add(V obj)
        Adds element into this structure.
        Parameters:
        obj - - element to add
        Returns:
        true if object has been added or false if it was already added
      • addAll

        reactor.core.publisher.Mono<Boolean> addAll(Collection<V> objects)
        Adds all elements contained in objects collection into this structure
        Parameters:
        objects - - elements to add
        Returns:
        true if at least one object has been added or false if 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 through otherLogNames.
        Parameters:
        otherLogNames - - name of instances
        Returns:
        number
      • mergeWith

        reactor.core.publisher.Mono<Void> mergeWith(String... otherLogNames)
        Merges multiple instances into this instance.
        Parameters:
        otherLogNames - - name of instances
        Returns:
        void