org.processmining.stream.model.datastructure.reservoir

Class ReservoirImpl<T>

java.lang.Object

org.processmining.stream.model.datastructure.AbstractDataStructure<T,ReservoirParameterDefinition>

org.processmining.stream.model.datastructure.reservoir.ReservoirImpl<T>

All Implemented Interfaces:

java.lang.Iterable<T>, DataStructure<T>, IterableDataStructure<T>, Reservoir<T>

public class ReservoirImpl<T>
extends AbstractDataStructure<T,ReservoirParameterDefinition>
implements Reservoir<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.processmining.stream.model.datastructure.DataStructure

DataStructure.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.ArrayList<T>	internalStore
protected int	maxSize
protected int	members
protected java.util.Random	rGen
protected int	totalElements

Fields inherited from interface org.processmining.stream.model.datastructure.DataStructure

FINITE_ITERABLE_DATA_STRUCTURES, FINITE_ITERABLE_POINTER_DATA_STRUCTURES, FINITE_POINTER_DATA_STRUCTURES, INFIITE_DATA_STRUCTURES, ITERABLE_DATA_STRUCTURES, POINTER_DATA_STRUCTURES

Constructor Summary

Constructors

Constructor and Description
ReservoirImpl(java.util.Map<ReservoirParameterDefinition,DSParameter<?>> params)

Method Summary

Modifier and Type	Method and Description
java.util.Collection<T>	add(T e) if we did not yet filled all spots, the element is always included.
void	clear()
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> c)
int	getCapacity()
long	getFrequencyOf(T e)
long	getSize()
DataStructure.Type	getType()
int	indexOf(T t)
boolean	isEmpty()
java.util.Iterator<T>	iterator()
void	set(int i, T t)
java.lang.String	toString()

Methods inherited from class org.processmining.stream.model.datastructure.AbstractDataStructure

getParameters, getUsedMemoryInBytes

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.stream.model.datastructure.DataStructure

getParameters, getUsedMemoryInBytes

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

internalStore

protected final java.util.ArrayList<T> internalStore

maxSize

protected final int maxSize

members

protected int members

totalElements

protected int totalElements

rGen

protected final java.util.Random rGen

Constructor Detail

ReservoirImpl

public ReservoirImpl(java.util.Map<ReservoirParameterDefinition,DSParameter<?>> params)

Method Detail

add

public java.util.Collection<T> add(T e)

if we did not yet filled all spots, the element is always included. if the reservoir is full and the (t+1)th data point comes in, it is included with probability n / t + 1.

Specified by:

add in interface DataStructure<T>

Returns:

clear

public void clear()

Specified by:

clear in interface DataStructure<T>

contains

public boolean contains(java.lang.Object o)

Specified by:

contains in interface DataStructure<T>

containsAll

public boolean containsAll(java.util.Collection<?> c)

indexOf

public int indexOf(T t)

Specified by:

indexOf in interface Reservoir<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface DataStructure<T>

iterator

public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

set

public void set(int i,
                T t)

Specified by:

set in interface Reservoir<T>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getType

public DataStructure.Type getType()

Specified by:

getType in interface DataStructure<T>

getSize

public long getSize()

Specified by:

getSize in interface DataStructure<T>

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface DataStructure<T>

getFrequencyOf

public long getFrequencyOf(T e)

Specified by:

getFrequencyOf in interface DataStructure<T>