org.processmining.streamanalysis.algorithms

Class XSEventReaderPerformanceAnalyzerImpl

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<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>

org.processmining.streamanalysis.algorithms.XSEventReaderPerformanceAnalyzerImpl

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object>, 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.lang.Object,java.lang.Object>

public class XSEventReaderPerformanceAnalyzerImpl
extends org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>
implements XSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>

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
XSEventReaderPerformanceAnalyzerImpl(java.lang.String name, org.processmining.stream.core.interfaces.XSVisualization<java.lang.Object> visualization, XSEventReaderPerformanceAnalyzerParameterImpl parameters)

Method Summary

Modifier and Type	Method and Description
void	addReader(org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object> reader)
protected java.lang.Object	computeCurrentResult()
java.util.Collection<org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object>>	getReaders()
java.lang.Class<org.processmining.eventstream.core.interfaces.XSEvent>	getTopic()
protected void	handleNextPacket(org.processmining.eventstream.core.interfaces.XSEvent packet)

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

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

XSEventReaderPerformanceAnalyzerImpl

public XSEventReaderPerformanceAnalyzerImpl(java.lang.String name,
                                            org.processmining.stream.core.interfaces.XSVisualization<java.lang.Object> visualization,
                                            XSEventReaderPerformanceAnalyzerParameterImpl parameters)

Method Detail

getTopic

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

Specified by:

getTopic in interface org.processmining.stream.core.interfaces.XSStronglyTyped<org.processmining.eventstream.core.interfaces.XSEvent>

addReader

public void addReader(org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object> reader)

Specified by:

addReader in interface XSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>

getReaders

public java.util.Collection<org.processmining.stream.core.interfaces.XSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object>> getReaders()

Specified by:

getReaders in interface XSStreamAnalyzer<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>

computeCurrentResult

protected java.lang.Object computeCurrentResult()

Specified by:

computeCurrentResult in class org.processmining.stream.core.abstracts.AbstractXSReader<org.processmining.eventstream.core.interfaces.XSEvent,java.lang.Object,java.lang.Object>

handleNextPacket

protected void handleNextPacket(org.processmining.eventstream.core.interfaces.XSEvent packet)

Specified by:

handleNextPacket in class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<org.processmining.eventstream.core.interfaces.XSEvent>