public abstract class AbstractXSEventReader<R,V,P extends XSEventReaderParameters> extends org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,R,V>
Constructor and Description |
---|
AbstractXSEventReader(java.lang.String name,
org.processmining.stream.core.interfaces.XSVisualization<V> visualization,
P parameters) |
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) |
computeCurrentResult, 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
protected boolean canReadPacket(XSEvent dataPacket)
protected int findEventIdentifierIndex(java.lang.String eventClassStr)
protected org.deckfour.xes.classification.XEventClass getActivity(XSEvent event)
public org.deckfour.xes.classification.XEventClass[] getEventClasses()
public P getParameters()
public java.lang.Class<XSEvent> getTopic()
public org.processmining.stream.core.interfaces.XSVisualization<V> getVisualization()
public void handleNextPacket(XSEvent event)
handleNextPacket
in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<XSEvent>
public abstract void processNewXSEvent(java.lang.String caseId, org.deckfour.xes.classification.XEventClass activity)
public void setEventClasses(org.deckfour.xes.classification.XEventClass[] eventClasses)
public void setVisualization(org.processmining.stream.core.interfaces.XSVisualization<V> visualization)
public long measureUsedMemory()
org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable
measureUsedMemory
in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<XSEvent>