DPCK - data packet typeANALYSIS_RES - result type of analyzerREFERENCE_TYPE - reference (comparison) model typeREADER_RESULT - result type of readers under studypublic 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>
| 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) |
| 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) |
addReader, computeCurrentResult, getParameters, getPermanentMetricResults, getPermanentResults, getReaders, getStream, handleNextPacket, shouldStoreResultPermanently, startXSRunnablegetCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, stopXSRunnabledeliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackageisPaused, isRunning, isStarted, isStopped, runactiveCount, 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, yieldequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, stop, stopXSRunnabledeliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandlepublic 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)
public java.lang.String[] getMetrics()
public org.processmining.framework.plugin.PluginContext getPluginContext()
public java.util.List<REFERENCE_TYPE> getReferences()
protected java.lang.String headerOf(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)
protected java.lang.String headerOf(REFERENCE_TYPE reference, int artifactNumber)
protected void printMetricsHeaders()
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>protected abstract java.lang.Iterable<ANALYSIS_RES> getResultsForMetrics(java.lang.String[] metrics, REFERENCE_TYPE reference, READER_RESULT readerResult)
protected java.lang.Iterable<java.lang.Iterable<ANALYSIS_RES>> analyze(READER_RESULT readerResult)
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>protected void printMetrics(long packet)
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>protected abstract java.lang.String toString(ANALYSIS_RES result)