Package org.apache.hadoop.hbase.util

Class ReservoirSample<T>

java.lang.Object

org.apache.hadoop.hbase.util.ReservoirSample<T>

@Private
public class ReservoirSample<T>
extends Object

The simple version of reservoir sampling implementation. It is enough for the usage in HBase.

See https://en.wikipedia.org/wiki/Reservoir_sampling.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	k
private int	n
private final List<T>	r

Constructor Summary

Constructors

Constructor	Description
ReservoirSample(int k)

Method Summary

Modifier and Type	Method	Description
void	add(Iterator<T> iter)
void	add(Stream<T> s)
void	add(T t)
List<T>	getSamplingResult()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

r

private final List<T> r

k

private final int k

n

private int n

Constructor Details

ReservoirSample

public ReservoirSample(int k)

Method Details

add

public void add(T t)

add

public void add(Iterator<T> iter)

add

public void add(Stream<T> s)

getSamplingResult

public List<T> getSamplingResult()