org.processmining.eventstream.readers.trie

Class AbstractStreamCaseTrieAlgorithmImpl<T,V extends VertexImpl<T>,G extends StreamTrieImpl<T,V>,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,V,G,R,P>

Type Parameters:

V -

G -

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>

Direct Known Subclasses:

StreamCaseTrieAlgorithmImpl

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>

constructs a prefix tree based on a sequence of objects within the stream. these objects could be activities, resources etc.

Author:

svzelst

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
AbstractStreamCaseTrieAlgorithmImpl(java.lang.String name, org.processmining.stream.core.interfaces.XSVisualization<R> visualization, P parameters, G graph)

Method Summary

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.

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

Constructor Detail

AbstractStreamCaseTrieAlgorithmImpl

public AbstractStreamCaseTrieAlgorithmImpl(java.lang.String name,
                                           org.processmining.stream.core.interfaces.XSVisualization<R> visualization,
                                           P parameters,
                                           G graph)

Method Detail

annotateEdge

protected abstract void annotateEdge(EdgeImpl<T,V> edge)

annotateVertex

protected abstract void annotateVertex(V vertex)

checkIfEdgeExists

protected org.processmining.framework.util.Pair<V,EdgeImpl<T,V>> checkIfEdgeExists(V source,
                                                                                   T targetObject)

constructNewAnnotatedVertex

protected abstract V constructNewAnnotatedVertex(T object)

getCurrentVertex

protected abstract V getCurrentVertex(java.lang.String caseId)

updateAdministrationAfterGraphUpdate

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. Optionally a list of removed edges is returned.

Parameters:

vertex -

edge -

caseId -

Returns:

handleNextTrie

protected abstract void handleNextTrie(G trie,
                                       EdgeImpl<T,V> newEdge,
                                       java.util.Collection<java.util.List<EdgeImpl<T,V>>> removedEdges)

createTargetObjectFromEvent

protected abstract T createTargetObjectFromEvent(XSEvent event)

getTrie

public G getTrie()

getParameters

public P getParameters()

getTopic

public java.lang.Class<XSEvent> getTopic()

handleNextPacket

protected void handleNextPacket(XSEvent packet)

Specified by:

handleNextPacket in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<XSEvent>