Package org.apache.wayang.profiler.log.sampling

Class ReservoirSampler<T>

java.lang.Object

org.apache.wayang.profiler.log.sampling.ReservoirSampler<T>

All Implemented Interfaces:

Sampler<T>

public abstract class ReservoirSampler<T>
extends Object
implements Sampler<T>

Utility to do reservoir sampling with competitions over shared space.

Constructor Summary

Constructors

Constructor	Description
ReservoirSampler(int sampleSize)

Method Summary

Modifier and Type	Method	Description
protected abstract T	letCompete(T candidate1, T candidate2, Random random)
List<T>	sample(Collection<T> set, Battle<T> battle, double selectionProbability)	Create a sample from a given Collection.

Methods inherited from class java.lang.Object

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

Constructor Details

ReservoirSampler

public ReservoirSampler(int sampleSize)

Method Details

sample

public List<T> sample(Collection<T> set,
 Battle<T> battle,
 double selectionProbability)

Description copied from interface: Sampler

Create a sample from a given Collection.

Specified by:

sample in interface Sampler<T>

Parameters:

set - the set of elements to be sampled from

battle - lets two elements compete

Returns:

the sample; may contain nulls dependent on the implementation

letCompete

protected abstract T letCompete(T candidate1,
 T candidate2,
 Random random)