public class StreamSocialNetworkMinerImpl extends org.processmining.eventstream.readers.trie.StreamCaseTrieAlgorithmImpl<ActivityResourcePair,StreamSocialNetworkManagerImpl,StreamSocialNetworkMinerParametersImpl>
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) |
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) |
annotateEdge, annotateVertex, constructNewAnnotatedVertex, getCurrentVertex, updateAdministrationAfterGraphUpdate
checkIfEdgeExists, getParameters, getTrie, handleNextPacket
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 StreamSocialNetworkMinerImpl(java.lang.String name, StreamSocialNetworkMinerParametersImpl parameters, StreamSocialNetworkManagerImpl mgr, org.processmining.eventstream.readers.trie.StreamTrieImpl<ActivityResourcePair,org.processmining.eventstream.readers.trie.VertexImpl<ActivityResourcePair>> graph)
public java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent> getTopic()
getTopic
in interface org.processmining.stream.core.interfaces.XSStronglyTyped<org.processmining.eventstream.core.interfaces.XSEvent>
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>
protected StreamSocialNetworkManagerImpl computeCurrentResult()
computeCurrentResult
in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,StreamSocialNetworkManagerImpl,StreamSocialNetworkManagerImpl>
protected java.lang.String castNewlyReceivedXAttribute(org.deckfour.xes.model.XAttribute attr)
protected ActivityResourcePair createTargetObjectFromEvent(org.processmining.eventstream.core.interfaces.XSEvent event)
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>
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)
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>