org.processmining.streambasedeventstorage.algorithms.abstr

Class AbstractXSEventStore<P extends org.processmining.eventstream.readers.abstr.XSEventReaderParameters>

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<T>

org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>,java.lang.Object>

org.processmining.streambasedeventstorage.algorithms.abstr.AbstractXSEventStore<P>

All Implemented Interfaces:

java.lang.Runnable, org.processmining.eventstream.models.XSEventReader<java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>>, org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStronglyTyped<org.processmining.eventstream.core.interfaces.XSEvent>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWritable<org.processmining.eventstream.core.interfaces.XSEvent>, XSEventStore

Direct Known Subclasses:

AbstractXSEventStoreReservoirSamplingImpl, XSEventStoreSlidingWindowImpl

public abstract class AbstractXSEventStore<P extends org.processmining.eventstream.readers.abstr.XSEventReaderParameters>
extends org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>,java.lang.Object>
implements XSEventStore

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface org.processmining.streambasedeventstorage.models.XSEventStore

XSEventStore.Factory, XSEventStore.Type

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields inherited from interface org.processmining.streambasedeventstorage.models.XSEventStore

KEY_MAX_ENTRY_SIZE, KEY_SEED, KEY_SIZE

Constructor Summary

Constructors

Constructor and Description
AbstractXSEventStore(java.lang.String name, P parameters)

Method Summary

Modifier and Type	Method and Description
protected void	addEventToTrace(org.processmining.eventstream.core.interfaces.XSEvent e, java.lang.String caseIdentifier)
protected java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	computeCurrentResult()
java.util.Collection<java.lang.String>	describedCases()
java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	getInFlux()
java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	getOutFlux()
P	getParameters()
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
java.util.Map<java.lang.String,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>>	getTraces()
java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	getWindow()
java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	project(java.lang.String caseIdentifier)
protected void	removeEventFromTrace(org.processmining.eventstream.core.interfaces.XSEvent e, java.lang.String caseIdentifier)

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSReader

getCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable

deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, handleNextPacket, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackage

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnable

isPaused, isRunning, isStarted, isStopped, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSReader

getCurrentResult

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.processmining.stream.core.interfaces.XSWritable

deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle

Methods inherited from interface org.processmining.stream.core.interfaces.XSVisualizable

getVisualization

Constructor Detail

AbstractXSEventStore

public AbstractXSEventStore(java.lang.String name,
                            P parameters)

Method Detail

getParameters

public P getParameters()

addEventToTrace

protected void addEventToTrace(org.processmining.eventstream.core.interfaces.XSEvent e,
                               java.lang.String caseIdentifier)

describedCases

public java.util.Collection<java.lang.String> describedCases()

Specified by:

describedCases in interface XSEventStore

getInFlux

public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getInFlux()

Specified by:

getInFlux in interface XSEventStore

getOutFlux

public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getOutFlux()

Specified by:

getOutFlux in interface XSEventStore

getTopic

public java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent> getTopic()

Specified by:

getTopic in interface org.processmining.stream.core.interfaces.XSStronglyTyped<org.processmining.eventstream.core.interfaces.XSEvent>

getTraces

public java.util.Map<java.lang.String,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>> getTraces()

getWindow

public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getWindow()

project

public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> project(java.lang.String caseIdentifier)

Specified by:

project in interface XSEventStore

removeEventFromTrace

protected void removeEventFromTrace(org.processmining.eventstream.core.interfaces.XSEvent e,
                                    java.lang.String caseIdentifier)

computeCurrentResult

protected java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> computeCurrentResult()

Specified by:

computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>,java.lang.Object>