public abstract class StreamCaseTrieAlgorithmImpl<T,R,P extends StreamCaseTrieAlgorithmParameters> extends AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P>
Modifier and Type | Field and Description |
---|---|
static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type> |
DEFAULT_ALLOWED_CASE_DATA_STRUCTURES |
Constructor and Description |
---|
StreamCaseTrieAlgorithmImpl(java.lang.String name,
org.processmining.stream.core.interfaces.XSVisualization<R> visualization,
P parameters,
StreamTrieImpl<T,VertexImpl<T>> graph) |
Modifier and Type | Method and Description |
---|---|
protected void |
annotateEdge(EdgeImpl<T,VertexImpl<T>> edge) |
protected void |
annotateVertex(VertexImpl<T> vertex) |
protected VertexImpl<T> |
constructNewAnnotatedVertex(T object) |
protected VertexImpl<T> |
getCurrentVertex(java.lang.String caseId) |
protected java.util.Collection<java.util.List<EdgeImpl<T,VertexImpl<T>>>> |
updateAdministrationAfterGraphUpdate(VertexImpl<T> vertex,
EdgeImpl<T,VertexImpl<T>> edge,
java.lang.String caseId)
Update any administration that is backing the trie, e.g., a data
structure in which cases point to nodes in the trie.
|
checkIfEdgeExists, createTargetObjectFromEvent, getParameters, getTopic, getTrie, handleNextPacket, handleNextTrie
computeCurrentResult, getCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, 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
public static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type> DEFAULT_ALLOWED_CASE_DATA_STRUCTURES
public StreamCaseTrieAlgorithmImpl(java.lang.String name, org.processmining.stream.core.interfaces.XSVisualization<R> visualization, P parameters, StreamTrieImpl<T,VertexImpl<T>> graph)
protected void annotateEdge(EdgeImpl<T,VertexImpl<T>> edge)
annotateEdge
in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>
protected void annotateVertex(VertexImpl<T> vertex)
annotateVertex
in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>
protected VertexImpl<T> constructNewAnnotatedVertex(T object)
constructNewAnnotatedVertex
in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>
protected VertexImpl<T> getCurrentVertex(java.lang.String caseId)
getCurrentVertex
in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>
protected java.util.Collection<java.util.List<EdgeImpl<T,VertexImpl<T>>>> updateAdministrationAfterGraphUpdate(VertexImpl<T> vertex, EdgeImpl<T,VertexImpl<T>> edge, java.lang.String caseId)
AbstractStreamCaseTrieAlgorithmImpl
updateAdministrationAfterGraphUpdate
in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>