Package org.apache.flink.api.java.sampling

Class Summary

Class	Description
BernoulliSampler<T>	A sampler implementation built upon a Bernoulli trail.
DistributedRandomSampler<T>	For sampling with fraction, the sample algorithms are natively distributed, while it's not true for fixed size sample algorithms.
IntermediateSampleData<T>	The data structure which is transferred between partitions and the coordinator for distributed random sampling.
PoissonSampler<T>	A sampler implementation based on the Poisson Distribution.
RandomSampler<T>	A data sample is a set of data selected from a statistical population by a defined procedure.
ReservoirSamplerWithoutReplacement<T>	A simple in memory implementation of Reservoir Sampling without replacement, and with only one pass through the input iteration whose size is unpredictable.
ReservoirSamplerWithReplacement<T>	A simple in memory implementation of Reservoir Sampling with replacement and with only one pass through the input iteration whose size is unpredictable.