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>
Constructor and Description |
---|
OnlineReplayerAlgorithm(org.processmining.plugins.etm.model.narytree.NAryTree tree,
gnu.trove.map.TObjectShortMap<java.lang.String> labelMap) |
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) |
canReadPacket, findEventIdentifierIndex, getActivity, getEventClasses, getParameters, getVisualization, handleNextPacket, measureUsedMemory, setEventClasses, setVisualization
getCurrentResult, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
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
isPaused, isRunning, isStarted, isStopped, run
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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public OnlineReplayerAlgorithm(org.processmining.plugins.etm.model.narytree.NAryTree tree, gnu.trove.map.TObjectShortMap<java.lang.String> labelMap)
public java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent> getTopic()
getTopic
in interface org.processmining.stream.core.interfaces.XSStronglyTyped<org.processmining.eventstream.core.interfaces.XSEvent>
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>
protected java.util.Map<java.lang.String,java.util.Map.Entry<? extends NAryTreeState,java.lang.Integer>> computeCurrentResult()
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>
public void processNewXSEvent(java.lang.String caseId, org.deckfour.xes.classification.XEventClass activity)
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>