public class XSEventStreamToXSStaticXSEventStreamReader extends org.processmining.stream.reader.staticstream.AbstractStaticStreamXSReader<XSEvent,XSStaticXSEventStream>
Constructor and Description |
---|
XSEventStreamToXSStaticXSEventStreamReader(java.lang.String name,
XSEventStreamToXSStaticEventStreamParameters params,
XSStaticXSEventStream container) |
XSEventStreamToXSStaticXSEventStreamReader(java.lang.String name,
XSEventStreamToXSStaticEventStreamParameters params,
XSStaticXSEventStream container,
org.processmining.framework.plugin.PluginContext context,
org.processmining.framework.providedobjects.ProvidedObjectID providedObjectID) |
Modifier and Type | Method and Description |
---|---|
protected XSStaticXSEventStream |
computeCurrentResult() |
java.lang.Class<XSEvent> |
getTopic() |
protected void |
writeContainerToContext(java.util.List<XSEvent> container,
org.processmining.framework.plugin.PluginContext context) |
getContainer, getContext, handleNextPacket, initializeVisualizer
getCurrentResult, getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
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
isPaused, isRunning, isStarted, isStopped, run
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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public XSEventStreamToXSStaticXSEventStreamReader(java.lang.String name, XSEventStreamToXSStaticEventStreamParameters params, XSStaticXSEventStream container)
public XSEventStreamToXSStaticXSEventStreamReader(java.lang.String name, XSEventStreamToXSStaticEventStreamParameters params, XSStaticXSEventStream container, org.processmining.framework.plugin.PluginContext context, org.processmining.framework.providedobjects.ProvidedObjectID providedObjectID)
public java.lang.Class<XSEvent> getTopic()
protected void writeContainerToContext(java.util.List<XSEvent> container, org.processmining.framework.plugin.PluginContext context)
writeContainerToContext
in class org.processmining.stream.reader.staticstream.AbstractStaticStreamXSReader<XSEvent,XSStaticXSEventStream>
protected XSStaticXSEventStream computeCurrentResult()
computeCurrentResult
in class org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,XSStaticXSEventStream,java.lang.Object>