org.processmining.streamanalysis.core.abstr

Class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,ANALYSIS_RESULT,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,ANALYSIS_RESULT,READER_RESULT,PARAM>

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,ANALYSIS_RESULT>>>, 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,ANALYSIS_RESULT>>,READER_RESULT>

Direct Known Subclasses:

AbstractComparisonXSStreamAnalyzer

public abstract class AbstractConccurrentReaderMapBasedXSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,ANALYSIS_RESULT,READER_RESULT,PARAM extends XSEventStreamAnalyzerParameters>
extends 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>
implements XSStreamAnalyzer<DPCK,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,READER_RESULT>

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
AbstractConccurrentReaderMapBasedXSStreamAnalyzer(java.lang.String name, org.processmining.stream.core.interfaces.XSStream<DPCK> stream, PARAM parameters)

Method Summary

Modifier and Type	Method and Description
void	addReader(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)
protected abstract ANALYSIS_RESULT	analyze(READER_RESULT readerResult)
protected java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>	computeCurrentResult()
PARAM	getParameters()
java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>	getPermanentMetricResults()
java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,READER_RESULT>>	getPermanentResults()
java.util.Collection<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>>	getReaders()
org.processmining.stream.core.interfaces.XSStream<DPCK>	getStream()
protected void	handleNextPacket(DPCK packet)
protected abstract void	printMetrics(long packetNumber)
protected abstract void	printMetricsHeaders()
protected abstract boolean	shouldStoreResultPermanently(READER_RESULT previouslyStoredResult, READER_RESULT currentResult)
void	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

AbstractConccurrentReaderMapBasedXSStreamAnalyzer

public AbstractConccurrentReaderMapBasedXSStreamAnalyzer(java.lang.String name,
                                                         org.processmining.stream.core.interfaces.XSStream<DPCK> stream,
                                                         PARAM parameters)

Method Detail

addReader

public void addReader(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)

Specified by:

addReader in interface XSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,READER_RESULT>

analyze

protected abstract ANALYSIS_RESULT analyze(READER_RESULT readerResult)

computeCurrentResult

protected java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>> computeCurrentResult()

Specified by:

computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,java.lang.Object>

getParameters

public PARAM getParameters()

getPermanentMetricResults

public java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>> getPermanentMetricResults()

getPermanentResults

public java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>,java.util.Map<java.lang.Long,READER_RESULT>> getPermanentResults()

getReaders

public java.util.Collection<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>> getReaders()

Specified by:

getReaders in interface XSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,READER_RESULT>

getStream

public org.processmining.stream.core.interfaces.XSStream<DPCK> getStream()

handleNextPacket

protected void handleNextPacket(DPCK packet)

Specified by:

handleNextPacket in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>>

printMetrics

protected abstract void printMetrics(long packetNumber)

printMetricsHeaders

protected abstract void printMetricsHeaders()

shouldStoreResultPermanently

protected abstract boolean shouldStoreResultPermanently(READER_RESULT previouslyStoredResult,
                                                        READER_RESULT currentResult)

startXSRunnable

public void startXSRunnable()

Specified by:

startXSRunnable in interface org.processmining.stream.core.interfaces.XSRunnable

Overrides:

startXSRunnable in class org.processmining.stream.core.abstracts.AbstractXSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,java.util.Map<org.processmining.stream.core.interfaces.XSReader<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,READER_RESULT>,java.util.Map<java.lang.Long,ANALYSIS_RESULT>>,java.lang.Object>