org.processmining.streamsocialnetworks.algorithms

Class StreamSocialNetworkMinerImpl

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

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

org.processmining.eventstream.readers.trie.StreamCaseTrieAlgorithmImpl<ActivityResourcePair,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>

org.processmining.streamsocialnetworks.algorithms.StreamSocialNetworkMinerImpl

All Implemented Interfaces:

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

public class StreamSocialNetworkMinerImpl
extends org.processmining.eventstream.readers.trie.StreamCaseTrieAlgorithmImpl<ActivityResourcePair,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>

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 org.processmining.eventstream.readers.trie.StreamCaseTrieAlgorithmImpl

DEFAULT_ALLOWED_CASE_DATA_STRUCTURES

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
StreamSocialNetworkMinerImpl(java.lang.String name, StreamSocialNetworkMinerParametersImpl parameters, StreamSocialNetworkManagerImpl mgr, org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> graph)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	castNewlyReceivedXAttribute(org.deckfour.xes.model.XAttribute attr)
protected StreamSocialNetworkManagerImpl	computeCurrentResult()
protected ActivityResourcePair	createTargetObjectFromEvent(org.processmining.eventstream.core.interfaces.XSEvent event)
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
protected void	handleNextTrie(org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> trie, org.processmining.eventstream.readers.trie.EdgeImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> newEdge, java.util.Collection<java.util.List<org.processmining.eventstream.readers.trie.EdgeImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>>>> removedEdges)

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

annotateEdge, annotateVertex, constructNewAnnotatedVertex, getCurrentVertex, updateAdministrationAfterGraphUpdate

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

checkIfEdgeExists, getParameters, getTrie, handleNextPacket

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

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

StreamSocialNetworkMinerImpl

public StreamSocialNetworkMinerImpl(java.lang.String name,
                                    StreamSocialNetworkMinerParametersImpl parameters,
                                    StreamSocialNetworkManagerImpl mgr,
                                    org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> graph)

Method Detail

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>

Overrides:

getTopic in class org.processmining.eventstream.readers.trie.AbstractStreamCaseTrieAlgorithmImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>,org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>>,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>

computeCurrentResult

protected StreamSocialNetworkManagerImpl computeCurrentResult()

Specified by:

computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,StreamSocialNetworkManagerImpl,StreamSocialNetworkManagerImpl>

castNewlyReceivedXAttribute

protected java.lang.String castNewlyReceivedXAttribute(org.deckfour.xes.model.XAttribute attr)

createTargetObjectFromEvent

protected ActivityResourcePair createTargetObjectFromEvent(org.processmining.eventstream.core.interfaces.XSEvent event)

Specified by:

createTargetObjectFromEvent in class org.processmining.eventstream.readers.trie.AbstractStreamCaseTrieAlgorithmImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>,org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>>,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>

handleNextTrie

protected void handleNextTrie(org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> trie,
                              org.processmining.eventstream.readers.trie.EdgeImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> newEdge,
                              java.util.Collection<java.util.List<org.processmining.eventstream.readers.trie.EdgeImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>>>> removedEdges)

Specified by:

handleNextTrie in class org.processmining.eventstream.readers.trie.AbstractStreamCaseTrieAlgorithmImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>,org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>>,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>