org.processmining.stream.model.datastructure.lossy

Class LossyCountingImpl<T>

java.lang.Object

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

org.processmining.stream.model.datastructure.lossy.LossyCountingImpl<T>

Type Parameters:

T -

All Implemented Interfaces:

java.lang.Iterable<T>, CounterBasedDataStructure<T>, DataStructure<T>, IterableDataStructure<T>, LossyCounting<T>

Direct Known Subclasses:

LossyCountingBudgetImpl, PointerBasedLossyCountingImpl

public class LossyCountingImpl<T>
extends AbstractDataStructure<T,LossyCountingParameterDefinition>
implements LossyCounting<T>

Lossy bucket algorithm, based on: Approximate Frequency Counts over Data Streams; Manku et al.; 2002;

Author:

svzelst

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.Map<T,java.lang.Integer>	buckets
protected int	bucketSize
protected int	currentBucket
protected double	epsilon
protected java.util.Map<T,java.lang.Integer>	frequencies
protected int	items
protected java.lang.Object	mutex

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
LossyCountingImpl(java.util.Map<LossyCountingParameterDefinition,DSParameter<?>> params)

Method Summary

Modifier and Type	Method and Description
java.util.Collection<T>	add(T e) 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()
protected java.util.Collection<T>	clean(java.util.Set<T> candidates)
void	clear()
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> c)
int	getBucketOf(T e)
int	getBucketSize()
int	getCapacity()
int	getCurrentBucket()
long	getFrequencyOf(T e)
double	getMaximumApproximationError()
long	getSize()
DataStructure.Type	getType()
boolean	isEmpty()
java.util.Iterator<T>	iterator()
protected void	remove(T t)
protected double	setBucketSize(int bucketSize)
protected int	setMaximumApproximationError(double epsilon)
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

buckets

protected final java.util.Map<T,java.lang.Integer> buckets

bucketSize

protected int bucketSize

currentBucket

protected int currentBucket

epsilon

protected double epsilon

frequencies

protected final java.util.Map<T,java.lang.Integer> frequencies

items

protected int items

mutex

protected java.lang.Object mutex

Constructor Detail

LossyCountingImpl

public LossyCountingImpl(java.util.Map<LossyCountingParameterDefinition,DSParameter<?>> params)

Method Detail

add

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

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()

clean

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

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)

getBucketOf

public int getBucketOf(T e)

Specified by:

getBucketOf in interface LossyCounting<T>

getBucketSize

public int getBucketSize()

Specified by:

getBucketSize in interface LossyCounting<T>

getCurrentBucket

public int getCurrentBucket()

Specified by:

getCurrentBucket in interface LossyCounting<T>

getFrequencyOf

public long getFrequencyOf(T e)

Specified by:

getFrequencyOf in interface DataStructure<T>

getMaximumApproximationError

public double getMaximumApproximationError()

Specified by:

getMaximumApproximationError in interface LossyCounting<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>

remove

protected void remove(T t)

setBucketSize

protected double setBucketSize(int bucketSize)

setMaximumApproximationError

protected int setMaximumApproximationError(double epsilon)

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>