public class TrieBasedEventCollectorImpl<E extends EventPayload,P extends StreamBasedEventStorageParametersImpl> extends AbstractEventCollector<org.deckfour.xes.model.XLog,org.deckfour.xes.model.XLog,P> implements XSEventStreamToXLogReader<P>
| Constructor and Description |
|---|
TrieBasedEventCollectorImpl(P parameters,
EventPayload.Factory<E> eventPayloadFactory,
org.processmining.streambasedeventstorage.models.XSEventStore eventStore) |
| Modifier and Type | Method and Description |
|---|---|
protected org.deckfour.xes.model.XLog |
computeCurrentResult() |
java.util.Map<java.lang.String,IncrementalPayloadTrie.Edge<E>> |
getFromEdges() |
long |
getNumberOfMemoryEntriesRepresentingEvents()
captures the actual memory consumption of the structure
|
java.util.Map<java.lang.String,IncrementalPayloadTrie.Edge<E>> |
getToEdges() |
long |
getTotalNumberOfEventsDescribedByMemory()
captures the number of events actually described
|
long |
getTotalPayloadMemoryOccupation()
fetches all stored metadata in the structure.
|
IncrementalPayloadTrie<E,IncrementalPayloadTrie.Edge<E>,IncrementalRootedPayloadGraph.Edge.Factory<E,IncrementalPayloadTrie.Edge<E>>> |
getTrie() |
protected void |
handleNextPacket(org.processmining.eventstream.core.interfaces.XSEvent event) |
addEventToCaseStore, addToBlacklist, getBackingEventStore, getCaseId, getParameters, getStorageParameters, getTopic, shouldConsiderCasegetCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnabledeliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackageisPaused, isRunning, isStarted, isStopped, runactiveCount, 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, yieldequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetStorageParametersgetName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnabledeliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandlepublic TrieBasedEventCollectorImpl(P parameters, EventPayload.Factory<E> eventPayloadFactory, org.processmining.streambasedeventstorage.models.XSEventStore eventStore)
protected org.deckfour.xes.model.XLog computeCurrentResult()
computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,org.deckfour.xes.model.XLog,org.deckfour.xes.model.XLog>public java.util.Map<java.lang.String,IncrementalPayloadTrie.Edge<E>> getFromEdges()
public long getNumberOfMemoryEntriesRepresentingEvents()
XSEventStreamToXLogReadergetNumberOfMemoryEntriesRepresentingEvents in interface XSEventStreamToXLogReader<P extends StreamBasedEventStorageParametersImpl>public java.util.Map<java.lang.String,IncrementalPayloadTrie.Edge<E>> getToEdges()
public long getTotalNumberOfEventsDescribedByMemory()
XSEventStreamToXLogReadergetTotalNumberOfEventsDescribedByMemory in interface XSEventStreamToXLogReader<P extends StreamBasedEventStorageParametersImpl>public long getTotalPayloadMemoryOccupation()
XSEventStreamToXLogReadergetTotalPayloadMemoryOccupation in interface XSEventStreamToXLogReader<P extends StreamBasedEventStorageParametersImpl>public IncrementalPayloadTrie<E,IncrementalPayloadTrie.Edge<E>,IncrementalRootedPayloadGraph.Edge.Factory<E,IncrementalPayloadTrie.Edge<E>>> getTrie()
protected void handleNextPacket(org.processmining.eventstream.core.interfaces.XSEvent event)
handleNextPacket in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<org.processmining.eventstream.core.interfaces.XSEvent>