public class XSEventStreamImpl extends org.processmining.stream.core.abstracts.AbstractXSStream<XSEvent> implements XSEventStream
Constructor and Description |
---|
XSEventStreamImpl(org.processmining.stream.core.enums.CommunicationType communicationType) |
XSEventStreamImpl(XSEventSignature signature,
org.processmining.stream.core.enums.CommunicationType communciationType) |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<XSEvent> |
getTopic() |
org.processmining.stream.core.interfaces.XSVisualization<?> |
getVisualization() |
connect, getSignature, transform
disconnect, getNumberOfPacketsSend, getWritables, getWriterDelegate, handleNextPacket, run, write
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
interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
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, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable
public XSEventStreamImpl(org.processmining.stream.core.enums.CommunicationType communicationType)
public XSEventStreamImpl(XSEventSignature signature, org.processmining.stream.core.enums.CommunicationType communciationType)
public java.lang.Class<XSEvent> getTopic()
getTopic
in interface org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>
public org.processmining.stream.core.interfaces.XSVisualization<?> getVisualization()
getVisualization
in interface org.processmining.stream.core.interfaces.XSVisualizable