org.processmining.streamanalysis.core.interfaces

Interface XSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,RESULT,READER_RESULT>

All Superinterfaces:

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

All Known Implementing Classes:

AbstractComparisonXSStreamAnalyzer, AbstractConccurrentReaderMapBasedXSStreamAnalyzer, AbstractProjRecPrecXSEventStreamAnalyzerImpl, AlignmentAPNAnalyzerImpl, PlaceConnectedAnalyzerImpl, ProjRecPrecXSEventStreamAPN2APNAnalyzerImpl, ProjRecPrecXSEventStreamPT2PTAnalyzerImpl, XSEventReaderPerformanceAnalyzerImpl

public interface XSStreamAnalyzer<DPCK extends org.processmining.stream.core.interfaces.XSDataPacket<?,?>,RESULT,READER_RESULT>
extends org.processmining.stream.core.interfaces.XSReader<DPCK,RESULT>

A XSStream Analyzer is a core node for the stream analysis framework. In a sense it is a strongly typed version of the more general subscriber node. It is also a reader itself and hence can only read from one stream.

Author:

svzelst

Method Summary

Modifier and Type	Method and Description
void	addReader(org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT> reader)
java.util.Collection<org.processmining.stream.core.interfaces.XSReader<DPCK,READER_RESULT>>	getReaders()

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

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

getTopic

Method Detail

addReader

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

getReaders

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