Trait reservoir_sampler::ReservoirSampler

pub trait ReservoirSampler {
    type Item;
    fn sample(&mut self, it: Self::Item) -> (usize, usize, Option<Self::Item>);
    fn samples(&self) -> &[Option<Self::Item>];
    fn lock(self) -> Vec<Option<Self::Item>>;
}

Associated Types

type Item

Each sampler only processes the same type of items.

Loading content...

Required methods

fn sample(&mut self, it: Self::Item) -> (usize, usize, Option<Self::Item>)

A sampler processes exactly one item each time, for the items come in as a stream.

Return

the sample function return a tuple contains 3 elements:

• a usize stands for what random number the current item gets
• a usize stands for how many items has been passed through so far
• an option of item that is replaced by the current item.

fn samples(&self) -> &[Option<Self::Item>]

A reservoir should know which items are held no matter if the sampling process is finished.

fn lock(self) -> Vec<Option<Self::Item>>

End the sampling process. Shuffling the order of the result is allowed.

Loading content...

Implementors

impl<T> ReservoirSampler for Reservoir<T>

type Item = T

fn sample(&mut self, it: Self::Item) -> (usize, usize, Option<Self::Item>)

fn samples(&self) -> &[Option<Self::Item>]

fn lock(self) -> Vec<Option<Self::Item>>

Loading content...