V
- G
- P
- public abstract class AbstractStreamCaseTrieAlgorithmImpl<T,V extends VertexImpl<T>,G extends StreamTrieImpl<T,V>,R,P extends StreamCaseTrieAlgorithmParameters> extends org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,R,R>
Constructor and Description |
---|
AbstractStreamCaseTrieAlgorithmImpl(java.lang.String name,
org.processmining.stream.core.interfaces.XSVisualization<R> visualization,
P parameters,
G graph) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
annotateEdge(EdgeImpl<T,V> edge) |
protected abstract void |
annotateVertex(V vertex) |
protected org.processmining.framework.util.Pair<V,EdgeImpl<T,V>> |
checkIfEdgeExists(V source,
T targetObject) |
protected abstract V |
constructNewAnnotatedVertex(T object) |
protected abstract T |
createTargetObjectFromEvent(XSEvent event) |
protected abstract V |
getCurrentVertex(java.lang.String caseId) |
P |
getParameters() |
java.lang.Class<XSEvent> |
getTopic() |
G |
getTrie() |
protected void |
handleNextPacket(XSEvent packet) |
protected abstract void |
handleNextTrie(G trie,
EdgeImpl<T,V> newEdge,
java.util.Collection<java.util.List<EdgeImpl<T,V>>> removedEdges) |
protected abstract java.util.Collection<java.util.List<EdgeImpl<T,V>>> |
updateAdministrationAfterGraphUpdate(V vertex,
EdgeImpl<T,V> 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.
|
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
protected abstract void annotateVertex(V vertex)
protected org.processmining.framework.util.Pair<V,EdgeImpl<T,V>> checkIfEdgeExists(V source, T targetObject)
protected abstract V getCurrentVertex(java.lang.String caseId)
protected abstract java.util.Collection<java.util.List<EdgeImpl<T,V>>> updateAdministrationAfterGraphUpdate(V vertex, EdgeImpl<T,V> edge, java.lang.String caseId)
vertex
- edge
- caseId
- protected abstract void handleNextTrie(G trie, EdgeImpl<T,V> newEdge, java.util.Collection<java.util.List<EdgeImpl<T,V>>> removedEdges)
public G getTrie()
public P getParameters()
public java.lang.Class<XSEvent> getTopic()