Struct ReservoirSampler 

pub struct ReservoirSampler { /* private fields */ }

Reservoir Sampler - Maintains uniform random sample from unbounded stream

Uses Algorithm R (Vitter, 1985) for efficient single-pass sampling.

Implementations

impl ReservoirSampler

pub fn new(capacity: usize) -> Self

Create a new reservoir sampler

Arguments

• capacity - Maximum number of samples to retain

pub fn add(&mut self, event: StreamEvent)

Add an event to the reservoir

Uses Algorithm R for O(1) average insertion time

pub fn sample(&self) -> &[StreamEvent]

Get the current sample

pub fn count(&self) -> u64

Get the number of events processed

pub fn clear(&mut self)

Clear the reservoir

pub fn stats(&self) -> ReservoirStats

Get statistics about the sampler

Trait Implementations

impl Clone for ReservoirSampler

fn clone(&self) -> ReservoirSampler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReservoirSampler

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

Formats the value using the given formatter.