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
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
XSEventStore.Factory, XSEventStore.Type
KEY_MAX_ENTRY_SIZE, KEY_SEED, KEY_SIZE
Constructor and Description |
---|
AbstractXSEventStore(java.lang.String name,
P parameters) |
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) |
getCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
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
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
getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable
public AbstractXSEventStore(java.lang.String name, P parameters)
public P getParameters()
protected void addEventToTrace(org.processmining.eventstream.core.interfaces.XSEvent e, java.lang.String caseIdentifier)
public java.util.Collection<java.lang.String> describedCases()
describedCases
in interface XSEventStore
public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getInFlux()
getInFlux
in interface XSEventStore
public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getOutFlux()
getOutFlux
in interface XSEventStore
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>
public java.util.Map<java.lang.String,java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>> getTraces()
public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> getWindow()
public java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> project(java.lang.String caseIdentifier)
project
in interface XSEventStore
protected void removeEventFromTrace(org.processmining.eventstream.core.interfaces.XSEvent e, java.lang.String caseIdentifier)
protected java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> computeCurrentResult()
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>