org.processmining.streamanalysis.core.abstr

Class AbstractComparisonXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,ANALYSIS_RES,REFERENCE_TYPE,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>

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<DPCK,ANALYSIS_RES,REFERENCE_TYPE,READER_RESULT,PARAM>

Type Parameters:

DPCK - data packet type

ANALYSIS_RES - result type of analyzer

REFERENCE_TYPE - reference (comparison) model type

READER_RESULT - result type of readers under study

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<DPCK,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>>>>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStronglyTyped<DPCK>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWritable<DPCK>, XSStreamAnalyzer<DPCK,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>>>,READER_RESULT>

Direct Known Subclasses:

AbstractProjRecPrecXSEventStreamAnalyzerImpl, AlignmentAPNAnalyzerImpl, PlaceConnectedAnalyzerImpl

public abstract class AbstractComparisonXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,ANALYSIS_RES,REFERENCE_TYPE,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>
extends AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>,READER_RESULT,PARAM>

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
AbstractComparisonXSStreamAnalyzer(org.processmining.framework.plugin.PluginContext context, java.lang.String name, org.processmining.stream.core.interfaces.XSStream<DPCK> stream, java.util.List<REFERENCE_TYPE> references, java.lang.String[] metrics, PARAM params)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>	analyze(READER_RESULT readerResult)
java.lang.String[]	getMetrics()
org.processmining.framework.plugin.PluginContext	getPluginContext()
java.util.List<REFERENCE_TYPE>	getReferences()
protected abstract java.lang.Iterable<ANALYSIS_RES>	getResultsForMetrics(java.lang.String[] metrics, REFERENCE_TYPE reference, READER_RESULT readerResult)
protected java.lang.String	headerOf(REFERENCE_TYPE reference, int artifactNumber)
protected java.lang.String	headerOf(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)
protected void	printMetrics(long packet)
protected void	printMetricsHeaders()
protected abstract java.lang.String	toString(ANALYSIS_RES result)

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

addReader, computeCurrentResult, getParameters, getPermanentMetricResults, getPermanentResults, getReaders, getStream, handleNextPacket, shouldStoreResultPermanently, 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

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

getTopic

Constructor Detail

AbstractComparisonXSStreamAnalyzer

public AbstractComparisonXSStreamAnalyzer(org.processmining.framework.plugin.PluginContext context,
                                          java.lang.String name,
                                          org.processmining.stream.core.interfaces.XSStream<DPCK> stream,
                                          java.util.List<REFERENCE_TYPE> references,
                                          java.lang.String[] metrics,
                                          PARAM params)

Method Detail

getMetrics

public java.lang.String[] getMetrics()

getPluginContext

public org.processmining.framework.plugin.PluginContext getPluginContext()

getReferences

public java.util.List<REFERENCE_TYPE> getReferences()

headerOf

protected java.lang.String headerOf(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)

headerOf

protected java.lang.String headerOf(REFERENCE_TYPE reference,
                                    int artifactNumber)

printMetricsHeaders

protected void printMetricsHeaders()

Specified by:

printMetricsHeaders in class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>

getResultsForMetrics

protected abstract java.lang.Iterable<ANALYSIS_RES> getResultsForMetrics(java.lang.String[] metrics,
                                                                         REFERENCE_TYPE reference,
                                                                         READER_RESULT readerResult)

analyze

protected java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>> analyze(READER_RESULT readerResult)

Specified by:

analyze in class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>

printMetrics

protected void printMetrics(long packet)

Specified by:

printMetrics in class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>>,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>

toString

protected abstract java.lang.String toString(ANALYSIS_RES result)