org.processmining.eventstream.readers.abstr

Class AbstractXSEventReader<R,V,P extends 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<XSEvent,R,V>

org.processmining.eventstream.readers.abstr.AbstractXSEventReader<R,V,P>

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<XSEvent,R>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWritable<XSEvent>

Direct Known Subclasses:

AbstractXSEventDelegateReader, CAxAADataStoreBasedDFAReaderImpl, StreamFlowerDiscoveryAlgorithmImpl

public abstract class AbstractXSEventReader<R,V,P extends XSEventReaderParameters>
extends org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,R,V>

Nested Class Summary

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

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

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AbstractXSEventReader(java.lang.String name, org.processmining.stream.core.interfaces.XSVisualization<V> visualization, P parameters)

Method Summary

Modifier and Type	Method and Description
protected boolean	canReadPacket(XSEvent dataPacket)
protected int	findEventIdentifierIndex(java.lang.String eventClassStr)
protected org.deckfour.xes.classification.XEventClass	getActivity(XSEvent event)
org.deckfour.xes.classification.XEventClass[]	getEventClasses()
P	getParameters()
java.lang.Class<XSEvent>	getTopic()
org.processmining.stream.core.interfaces.XSVisualization<V>	getVisualization()
void	handleNextPacket(XSEvent event)
long	measureUsedMemory() measures actual memory currently used by the algorithm.
abstract void	processNewXSEvent(java.lang.String caseId, org.deckfour.xes.classification.XEventClass activity)
void	setEventClasses(org.deckfour.xes.classification.XEventClass[] eventClasses)
void	setVisualization(org.processmining.stream.core.interfaces.XSVisualization<V> visualization)

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

computeCurrentResult, getCurrentResult, 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, isTrackingPerformance, isTrackPerformance, 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.XSRunnable

getName, isPaused, isRunning, isStarted, isStopped, stop

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

Constructor Detail

AbstractXSEventReader

public AbstractXSEventReader(java.lang.String name,
                             org.processmining.stream.core.interfaces.XSVisualization<V> visualization,
                             P parameters)

Method Detail

canReadPacket

protected boolean canReadPacket(XSEvent dataPacket)

findEventIdentifierIndex

protected int findEventIdentifierIndex(java.lang.String eventClassStr)

getActivity

protected org.deckfour.xes.classification.XEventClass getActivity(XSEvent event)

getEventClasses

public org.deckfour.xes.classification.XEventClass[] getEventClasses()

getParameters

public P getParameters()

getTopic

public java.lang.Class<XSEvent> getTopic()

getVisualization

public org.processmining.stream.core.interfaces.XSVisualization<V> getVisualization()

Specified by:

getVisualization in interface org.processmining.stream.core.interfaces.XSVisualizable

Overrides:

getVisualization in class org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,R,V>

handleNextPacket

public void handleNextPacket(XSEvent event)

Specified by:

handleNextPacket in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<XSEvent>

processNewXSEvent

public abstract void processNewXSEvent(java.lang.String caseId,
                                       org.deckfour.xes.classification.XEventClass activity)

setEventClasses

public void setEventClasses(org.deckfour.xes.classification.XEventClass[] eventClasses)

setVisualization

public void setVisualization(org.processmining.stream.core.interfaces.XSVisualization<V> visualization)

measureUsedMemory

public long measureUsedMemory()

Description copied from class: org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable

measures actual memory currently used by the algorithm. may be changed by child classes to define a more specific measurement. For example, by only measuring the size of certain data structures within the child class.

Overrides:

measureUsedMemory in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<XSEvent>

Returns: