org.processmining.onlineconformance.stream

Class OnlineReplayerAlgorithm

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,R,V>

org.processmining.eventstream.readers.abstr.AbstractXSEventReader<java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>,java.lang.Object,OnlineReplayerParameters>

org.processmining.onlineconformance.stream.OnlineReplayerAlgorithm

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>>, 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>

public class OnlineReplayerAlgorithm
extends org.processmining.eventstream.readers.abstr.AbstractXSEventReader<java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>,java.lang.Object,OnlineReplayerParameters>

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
OnlineReplayerAlgorithm(org.processmining.plugins.etm.model.narytree.NAryTree tree, gnu.trove.map.TObjectShortMap<java.lang.String> labelMap)

Method Summary

Modifier and Type	Method and Description
protected java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>	computeCurrentResult()
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
void	processNewXSEvent(java.lang.String caseId, org.deckfour.xes.classification.XEventClass activity)

Methods inherited from class org.processmining.eventstream.readers.abstr.AbstractXSEventReader

canReadPacket, findEventIdentifierIndex, getActivity, getEventClasses, getParameters, getVisualization, handleNextPacket, measureUsedMemory, setEventClasses, setVisualization

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

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

OnlineReplayerAlgorithm

public OnlineReplayerAlgorithm(org.processmining.plugins.etm.model.narytree.NAryTree tree,
                               gnu.trove.map.TObjectShortMap<java.lang.String> labelMap)

Method Detail

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>

Overrides:

getTopic in class org.processmining.eventstream.readers.abstr.AbstractXSEventReader<java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>,java.lang.Object,OnlineReplayerParameters>

computeCurrentResult

protected java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>> computeCurrentResult()

Specified by:

computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>,java.lang.Object>

processNewXSEvent

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

Specified by:

processNewXSEvent in class org.processmining.eventstream.readers.abstr.AbstractXSEventReader<java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>>,java.lang.Object,OnlineReplayerParameters>