Struct CountMinSketch 

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

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, C> CountMinSketch<K, C>

where K: Hash + ?Sized, 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, V: ?Sized>(&mut self, key: &Q, value: &V) -> C

where Q: Hash + ?Sized, K: Borrow<Q>, C: for<'a> AddAssign<&'a V> + IntersectPlusUnionIsPlus,

“Visit” an element.

pub fn union_assign<Q>(&mut self, key: &Q, value: &C)

where Q: Hash + ?Sized, K: Borrow<Q>,

Union the aggregated value for key with value.

pub fn get<Q>(&self, key: &Q) -> C

where Q: Hash + ?Sized, 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 duplicate 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> Deserialize<'de> for CountMinSketch<K, C>

where C: Deserialize<'de> + New, <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> Serialize for CountMinSketch<K, C>

where C: Serialize + New, <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.