Struct streaming_algorithms::CountMinSketch

pub struct CountMinSketch<K: ?Sized, C: New> { /* fields omitted */ }

An implementation of a count-min sketch data structure with conservative updating for increased accuracy.

This data structure is also known as a counting Bloom filter.

See An Improved Data Stream Summary: The Count-Min Sketch and its Applications and New Directions in Traffic Measurement and Accounting for background on the count-min sketch with conservative updating.

Implementations

impl<K: ?Sized, C> CountMinSketch<K, C> where
    K: Hash,
    C: New + for<'a> UnionAssign<&'a C> + Intersect, 

pub fn new(probability: f64, tolerance: f64, config: C::Config) -> Self

Create an empty CountMinSketch data structure with the specified error tolerance.

pub fn push<Q: ?Sized, V: ?Sized>(&mut self, key: &Q, value: &V) -> C where
    Q: Hash,
    K: Borrow<Q>,
    C: for<'a> AddAssign<&'a V>, 

"Visit" an element.

pub fn union_assign<Q: ?Sized>(&mut self, key: &Q, value: &C) where
    Q: Hash,
    K: Borrow<Q>, 

Union the aggregated value for key with value.

pub fn get<Q: ?Sized>(&self, key: &Q) -> C where
    Q: Hash,
    K: Borrow<Q>, 

Retrieve an estimate of the aggregated value for key.

pub fn clear(&mut self)

Clears the CountMinSketch data structure, as if it was new.

Trait Implementations

impl<K: ?Sized, C: New + Clone> Clone for CountMinSketch<K, C>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K: ?Sized, C: New> Debug for CountMinSketch<K, C>

fn fmt(&self, fmt: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'de, K: ?Sized, C: New> Deserialize<'de> for CountMinSketch<K, C> where
    C: Deserialize<'de>,
    <C as New>::Config: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<K: ?Sized, C: New> Serialize for CountMinSketch<K, C> where
    C: Serialize,
    <C as New>::Config: Serialize, 

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.