Uses of Class
org.apache.flink.api.java.sampling.DistributedRandomSampler

Packages that use DistributedRandomSampler

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

Uses of DistributedRandomSampler in org.apache.flink.api.java.sampling

Subclasses of DistributedRandomSampler in org.apache.flink.api.java.sampling

Modifier and Type	Class and Description
class	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.
class	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.