flowstats 0.1.2

Collection of stream analytics algorithms: cardinality, quantiles, frequency, sampling, and more
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! Stream sampling algorithms
//!
//! This module provides algorithms for maintaining random samples from streams.
//! Useful when you need representative samples but can't store all data.
//!
//! # Example
//!
//! ```
//! use flowstats::sampling::ReservoirSampler;
//!
//! let mut sampler = ReservoirSampler::<i32>::new(10);
//!
//! // Stream millions of items, keep uniform sample of 10
//! for i in 0..1_000_000 {
//!     sampler.add(i);
//! }
//!
//! // Each item had equal probability of being sampled
//! let sample = sampler.sample();
//! assert_eq!(sample.len(), 10);
//! ```

mod reservoir;

pub use reservoir::ReservoirSampler;