org.processmining.stream.model.datastructure.decay

Class AbstractForwardDecayDataStructureImpl<T,P extends DSParameterDefinition>

java.lang.Object

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

org.processmining.stream.model.datastructure.decay.AbstractForwardDecayDataStructureImpl<T,P>

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractPointerBasedForwardDecayDataStructure, ForwardExponentialDecayDataStructureImpl

public abstract class AbstractForwardDecayDataStructureImpl<T,P extends DSParameterDefinition>
extends AbstractDataStructure<T,P>
implements DecayDataStructure<T>

Nested Class Summary

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

DataStructure.Type

Field Summary

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
AbstractForwardDecayDataStructureImpl(java.util.Map<P,DSParameter<?>> params, DecayFunction f, int renewalRate, double threshold)

Method Summary

Modifier and Type	Method and Description
java.util.Collection<T>	add(T t) add elements to a stream based data structure may lead to removal of other elements in the data structure If possible, the implementing algorithm will return a collection of elements.
protected java.util.Collection<T>	clean()
void	clear()
boolean	contains(java.lang.Object o)
protected int	findMaxIndexOfItemsToRemove(int from, int to, double divisor)
int	getCapacity()
java.util.Map<T,java.util.Queue<java.lang.ref.WeakReference<ItemDecayValuePair<T>>>>	getCounts()
DecayFunction	getDecayFunction()
long	getFrequencyOf(T e)
java.util.List<ItemDecayValuePair<T>>	getItems()
long	getLandMark()
int	getRenewalRate()
long	getSize()
double	getThreshold()
long	getTime()
DataStructure.Type	getType()
boolean	isEmpty()
java.util.Iterator<T>	iterator()
void	setLandMark(long landMark)
void	setTime(long time)

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, toString, wait, wait, wait

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

getParameters, getUsedMemoryInBytes

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

AbstractForwardDecayDataStructureImpl

public AbstractForwardDecayDataStructureImpl(java.util.Map<P,DSParameter<?>> params,
                                             DecayFunction f,
                                             int renewalRate,
                                             double threshold)

Method Detail

add

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

Description copied from interface: DataStructure

add elements to a stream based data structure may lead to removal of other elements in the data structure If possible, the implementing algorithm will return a collection of elements.

Specified by:

add in interface DataStructure<T>

Returns:

clean

protected java.util.Collection<T> clean()

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>

findMaxIndexOfItemsToRemove

protected int findMaxIndexOfItemsToRemove(int from,
                                          int to,
                                          double divisor)

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface DataStructure<T>

getCounts

public java.util.Map<T,java.util.Queue<java.lang.ref.WeakReference<ItemDecayValuePair<T>>>> getCounts()

getDecayFunction

public DecayFunction getDecayFunction()

Specified by:

getDecayFunction in interface DecayDataStructure<T>

getFrequencyOf

public long getFrequencyOf(T e)

Specified by:

getFrequencyOf in interface DataStructure<T>

getItems

public java.util.List<ItemDecayValuePair<T>> getItems()

getLandMark

public long getLandMark()

getRenewalRate

public int getRenewalRate()

getSize

public long getSize()

Specified by:

getSize in interface DataStructure<T>

getThreshold

public double getThreshold()

getTime

public long getTime()

getType

public DataStructure.Type getType()

Specified by:

getType in interface DataStructure<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>

setLandMark

public void setLandMark(long landMark)

setTime

public void setTime(long time)