public abstract class AbstractStaticStreamXSReader<T extends XSDataPacket<?,?>,S extends XSStaticStream<T>> extends AbstractXSReader<T,S,java.lang.Object>
Constructor and Description |
---|
AbstractStaticStreamXSReader(java.lang.String name,
XSVisualization<java.lang.Object> visualization,
int totalNumberOfEvents,
XSStaticStream<T> container) |
AbstractStaticStreamXSReader(java.lang.String name,
XSVisualization<java.lang.Object> visualization,
int totalNumberOfEvents,
XSStaticStream<T> container,
org.processmining.framework.plugin.PluginContext context) |
Modifier and Type | Method and Description |
---|---|
XSStaticStream<T> |
getContainer() |
org.processmining.framework.plugin.PluginContext |
getContext() |
protected void |
handleNextPacket(T packet) |
protected XSVisualization<java.lang.Object> |
initializeVisualizer(int totalNumberOfEvents) |
protected abstract void |
writeContainerToContext(java.util.List<T> container,
org.processmining.framework.plugin.PluginContext context) |
computeCurrentResult, 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
getName, isPaused, isRunning, isStarted, isStopped, stop
deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle
getTopic
public AbstractStaticStreamXSReader(java.lang.String name, XSVisualization<java.lang.Object> visualization, int totalNumberOfEvents, XSStaticStream<T> container)
public AbstractStaticStreamXSReader(java.lang.String name, XSVisualization<java.lang.Object> visualization, int totalNumberOfEvents, XSStaticStream<T> container, org.processmining.framework.plugin.PluginContext context)
protected XSVisualization<java.lang.Object> initializeVisualizer(int totalNumberOfEvents)
public XSStaticStream<T> getContainer()
protected void handleNextPacket(T packet)
handleNextPacket
in class AbstractXSRunnableXSWritable<T extends XSDataPacket<?,?>>
protected abstract void writeContainerToContext(java.util.List<T> container, org.processmining.framework.plugin.PluginContext context)
public org.processmining.framework.plugin.PluginContext getContext()