Struct AtomicHyperLogLog 

pub struct AtomicHyperLogLog<S = DefaultHasher> { /* private fields */ }

HyperLogLog is a data structure for the “count-distinct problem”, approximating the number of distinct elements in a multiset. AtomicHyperLogLog is the thread-safe counterpart of HyperLogLog.

Example

use hyperloglockless::AtomicHyperLogLog;

let hll = AtomicHyperLogLog::new(16);
hll.insert("42");
hll.insert("🦀");

let count = hll.count();

Implementations

impl<S: BuildHasher> AtomicHyperLogLog<S>

pub fn with_hasher(precision: u8, hasher: S) -> Self

Returns a new AtomicHyperLogLog with 1 << precision registers (1 byte each) using the provided hasher.

impl AtomicHyperLogLog

pub fn new(precision: u8) -> AtomicHyperLogLog<DefaultHasher>

Returns a new Self with 1 << precision registers (1 byte each) using the default hasher with a random seed.

pub fn seeded(precision: u8, seed: u128) -> AtomicHyperLogLog<DefaultHasher>

Returns a new Self with 1 << precision registers (1 byte each) using the default hasher seeded with seed.

impl<S: BuildHasher> AtomicHyperLogLog<S>

pub fn len(&self) -> usize

Returns the number registers in self.

pub fn count(&self) -> usize

Returns the approximate number of elements in self.

impl<S: BuildHasher> AtomicHyperLogLog<S>

pub fn iter(&self) -> impl Iterator<Item = u8> + '_

Returns an iterator over the value of each register.

pub fn insert<T: Hash + ?Sized>(&self, value: &T)

Inserts the item into the HyperLogLog.

pub fn insert_hash(&self, hash: u64)

Inserts the hash of an item into the HyperLogLog.

pub fn insert_all<T: Hash, I: IntoIterator<Item = T>>(&self, iter: I)

Inserts all the items in iter into the self. Immutable version of Self::extend.

pub fn union(&self, other: &Self) -> Result<(), Error>

Merges another HyperLogLog into self, updating the count. Returns Err(Error::IncompatibleLength) if the two HyperLogLogs have different length (Self::len).

pub fn raw_count(&self) -> f64

Returns the approximate number of elements in self.

pub fn parts<'a>(&'a self) -> (&'a [AtomicU8], &'a S, usize, f64)

Low level method to expose de/serializable parts of self.

pub fn from_parts( registers: Box<[AtomicU8]>, hasher: S, zeros: usize, sum: f64, ) -> Self

Low level method to construct Self de/serializable parts.

Trait Implementations

impl<S: BuildHasher + Clone> Clone for AtomicHyperLogLog<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug> Debug for AtomicHyperLogLog<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Hash, S: BuildHasher> Extend<T> for AtomicHyperLogLog<S>

fn extend<I: IntoIterator<Item = T>>(&mut self, iter: I)

Extends a collection with the contents of an iterator.

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.

impl<S: BuildHasher> PartialEq for AtomicHyperLogLog<S>

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<S: BuildHasher> Eq for AtomicHyperLogLog<S>