org.processmining.eventstream.readers.trie

Class StreamCaseTrieAlgorithmImpl<T,R,P extends StreamCaseTrieAlgorithmParameters>

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<XSEvent,R,R>

org.processmining.eventstream.readers.trie.AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P>

org.processmining.eventstream.readers.trie.StreamCaseTrieAlgorithmImpl<T,R,P>

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<XSEvent,R>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWritable<XSEvent>

public abstract class StreamCaseTrieAlgorithmImpl<T,R,P extends StreamCaseTrieAlgorithmParameters>
extends AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type>	DEFAULT_ALLOWED_CASE_DATA_STRUCTURES

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
StreamCaseTrieAlgorithmImpl(java.lang.String name, org.processmining.stream.core.interfaces.XSVisualization<R> visualization, P parameters, StreamTrieImpl<T,VertexImpl<T>> graph)

Method Summary

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.

Methods inherited from class org.processmining.eventstream.readers.trie.AbstractStreamCaseTrieAlgorithmImpl

checkIfEdgeExists, createTargetObjectFromEvent, getParameters, getTopic, getTrie, handleNextPacket, handleNextTrie

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, 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.XSRunnable

getName, isPaused, isRunning, isStarted, isStopped, stop

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

Field Detail

DEFAULT_ALLOWED_CASE_DATA_STRUCTURES

public static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type> DEFAULT_ALLOWED_CASE_DATA_STRUCTURES

Constructor Detail

StreamCaseTrieAlgorithmImpl

public StreamCaseTrieAlgorithmImpl(java.lang.String name,
                                   org.processmining.stream.core.interfaces.XSVisualization<R> visualization,
                                   P parameters,
                                   StreamTrieImpl<T,VertexImpl<T>> graph)

Method Detail

annotateEdge

protected void annotateEdge(EdgeImpl<T,VertexImpl<T>> edge)

Specified by:

annotateEdge in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>

annotateVertex

protected void annotateVertex(VertexImpl<T> vertex)

Specified by:

annotateVertex in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>

constructNewAnnotatedVertex

protected VertexImpl<T> constructNewAnnotatedVertex(T object)

Specified by:

constructNewAnnotatedVertex in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>

getCurrentVertex

protected VertexImpl<T> getCurrentVertex(java.lang.String caseId)

Specified by:

getCurrentVertex in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>

updateAdministrationAfterGraphUpdate

protected java.util.Collection<java.util.List<EdgeImpl<T,VertexImpl<T>>>> updateAdministrationAfterGraphUpdate(VertexImpl<T> vertex,
                                                                                                               EdgeImpl<T,VertexImpl<T>> edge,
                                                                                                               java.lang.String caseId)

Description copied from class: AbstractStreamCaseTrieAlgorithmImpl

Update any administration that is backing the trie, e.g., a data structure in which cases point to nodes in the trie. Optionally a list of removed edges is returned.

Specified by:

updateAdministrationAfterGraphUpdate in class AbstractStreamCaseTrieAlgorithmImpl<T,VertexImpl<T>,StreamTrieImpl<T,VertexImpl<T>>,R,P extends StreamCaseTrieAlgorithmParameters>

Returns: