org.processmining.streamanalysis.algorithms

Class PlaceConnectedAnalyzerImpl

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<DPCK,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,java.lang.Object>

org.processmining.streamanalysis.core.abstr.AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>,READER_RESULT,PARAM>

org.processmining.streamanalysis.core.abstr.AbstractComparisonXSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Double,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,XSEventStreamAnalyzerParameters>

org.processmining.streamanalysis.algorithms.PlaceConnectedAnalyzerImpl

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.util.Map<org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,org.processmining.acceptingpetrinet.models.AcceptingPetriNet>,java.util.Map<java.lang.Long,java.lang.Iterable<java.lang.Iterable<java.lang.Double>>>>>, 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>, XSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.util.Map<org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,org.processmining.acceptingpetrinet.models.AcceptingPetriNet>,java.util.Map<java.lang.Long,java.lang.Iterable<java.lang.Iterable<java.lang.Double>>>>,org.processmining.acceptingpetrinet.models.AcceptingPetriNet>

public class PlaceConnectedAnalyzerImpl
extends AbstractComparisonXSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Double,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,XSEventStreamAnalyzerParameters>

compares Petri nets by creating a matrix that captures the distances between transitions based on whether or not they are connected by means of a place. this method only works if the labels within the petri net are unique.

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
PlaceConnectedAnalyzerImpl(org.processmining.framework.plugin.PluginContext context, java.lang.String name, org.processmining.stream.core.interfaces.XSStream<org.processmining.eventstream.core.interfaces.XSEvent> stream, java.util.List<org.processmining.acceptingpetrinet.models.AcceptingPetriNet> references, XSEventStreamAnalyzerParameters params)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Iterable<java.lang.Double>	getResultsForMetrics(java.lang.String[] metrics, org.processmining.acceptingpetrinet.models.AcceptingPetriNet reference, org.processmining.acceptingpetrinet.models.AcceptingPetriNet readerResult)
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
protected boolean	shouldStoreResultPermanently(org.processmining.acceptingpetrinet.models.AcceptingPetriNet previouslyStoredResult, org.processmining.acceptingpetrinet.models.AcceptingPetriNet currentResult)
protected java.lang.String	toString(java.lang.Double result)

Methods inherited from class org.processmining.streamanalysis.core.abstr.AbstractComparisonXSStreamAnalyzer

analyze, getMetrics, getPluginContext, getReferences, headerOf, headerOf, printMetrics, printMetricsHeaders

Methods inherited from class org.processmining.streamanalysis.core.abstr.AbstractConccurrentReaderMapBasedXSStreamAnalyzer

addReader, computeCurrentResult, getParameters, getPermanentMetricResults, getPermanentResults, getReaders, getStream, handleNextPacket, startXSRunnable

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

getCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, 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.XSReader

getCurrentResult

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, stop, stopXSRunnable

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSVisualizable

getVisualization

Constructor Detail

PlaceConnectedAnalyzerImpl

public PlaceConnectedAnalyzerImpl(org.processmining.framework.plugin.PluginContext context,
                                  java.lang.String name,
                                  org.processmining.stream.core.interfaces.XSStream<org.processmining.eventstream.core.interfaces.XSEvent> stream,
                                  java.util.List<org.processmining.acceptingpetrinet.models.AcceptingPetriNet> references,
                                  XSEventStreamAnalyzerParameters params)

Method Detail

getTopic

public java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent> getTopic()

getResultsForMetrics

protected java.lang.Iterable<java.lang.Double> getResultsForMetrics(java.lang.String[] metrics,
                                                                    org.processmining.acceptingpetrinet.models.AcceptingPetriNet reference,
                                                                    org.processmining.acceptingpetrinet.models.AcceptingPetriNet readerResult)

Specified by:

getResultsForMetrics in class AbstractComparisonXSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Double,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,XSEventStreamAnalyzerParameters>

toString

protected java.lang.String toString(java.lang.Double result)

Specified by:

toString in class AbstractComparisonXSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Double,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,XSEventStreamAnalyzerParameters>

shouldStoreResultPermanently

protected boolean shouldStoreResultPermanently(org.processmining.acceptingpetrinet.models.AcceptingPetriNet previouslyStoredResult,
                                               org.processmining.acceptingpetrinet.models.AcceptingPetriNet currentResult)

Specified by:

shouldStoreResultPermanently in class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Iterable<java.lang.Iterable<java.lang.Double>>,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,XSEventStreamAnalyzerParameters>