org.processmining.streambasedeventlog.algorithms.abstr

Class AbstractEventCollector<T,V,P extends StreamBasedEventStorageParametersImpl>

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

org.processmining.streambasedeventlog.algorithms.abstr.AbstractEventCollector<T,V,P>

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,T>, 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>, XSEventStreamBasedEventStore<T,P>

Direct Known Subclasses:

TrieBasedEventCollectorImpl

public abstract class AbstractEventCollector<T,V,P extends StreamBasedEventStorageParametersImpl>
extends org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,T,V>
implements XSEventStreamBasedEventStore<T,P>

abstract entity that handles mapping events to tuple-based encoding (i.e. long[]), storing parameters etc.

Author:

svzelst resulting class class to visualize

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
AbstractEventCollector(java.lang.String name, P parameters, org.processmining.streambasedeventstorage.models.XSEventStore eventStore)

Method Summary

Modifier and Type	Method and Description
protected java.util.List<org.processmining.eventstream.core.interfaces.XSEvent>	addEventToCaseStore(org.processmining.eventstream.core.interfaces.XSEvent e)
protected void	addToBlacklist(java.lang.String caseId)
org.processmining.streambasedeventstorage.models.XSEventStore	getBackingEventStore()
protected java.lang.String	getCaseId(org.processmining.eventstream.core.interfaces.XSEvent event)
protected P	getParameters()
P	getStorageParameters()
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
protected boolean	shouldConsiderCase(java.lang.String caseId)

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

computeCurrentResult, getCurrentResult, getVisualization, 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, handleNextPacket, isTrackingPerformance, isTrackPerformance, measureUsedMemory, 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.XSReader

getCurrentResult

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSVisualizable

getVisualization

Constructor Detail

AbstractEventCollector

public AbstractEventCollector(java.lang.String name,
                              P parameters,
                              org.processmining.streambasedeventstorage.models.XSEventStore eventStore)

Method Detail

getStorageParameters

public P getStorageParameters()

Specified by:

getStorageParameters in interface XSEventStreamBasedEventStore<T,P extends StreamBasedEventStorageParametersImpl>

addEventToCaseStore

protected java.util.List<org.processmining.eventstream.core.interfaces.XSEvent> addEventToCaseStore(org.processmining.eventstream.core.interfaces.XSEvent e)

getCaseId

protected java.lang.String getCaseId(org.processmining.eventstream.core.interfaces.XSEvent event)

getParameters

protected P getParameters()

getBackingEventStore

public org.processmining.streambasedeventstorage.models.XSEventStore getBackingEventStore()

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>

shouldConsiderCase

protected boolean shouldConsiderCase(java.lang.String caseId)

addToBlacklist

protected void addToBlacklist(java.lang.String caseId)