public class CPNModelToXSEventStreamAuthorImpl extends org.processmining.stream.core.abstracts.AbstractXSAuthor<XSEvent,java.lang.String>
Modifier and Type | Field and Description |
---|---|
protected int |
currentRepetition |
protected long |
currentStep |
protected org.cpntools.accesscpn.engine.highlevel.instance.State |
initialState |
protected long |
lastSend |
protected java.math.BigInteger |
lastStep |
protected CPN2XSEventStreamParameters |
parameters |
protected org.cpntools.accesscpn.model.PetriNet |
pn |
protected org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator |
simulator |
protected long |
waitTimeNs |
protected org.deckfour.xes.factory.XFactory |
xfact |
Constructor and Description |
---|
CPNModelToXSEventStreamAuthorImpl(org.cpntools.accesscpn.model.PetriNet pn,
org.cpntools.accesscpn.engine.highlevel.instance.State iState,
org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator sim,
CPN2XSEventStreamParameters parameters) |
Modifier and Type | Method and Description |
---|---|
protected XSEvent |
addData(XSEvent event,
org.cpntools.accesscpn.engine.highlevel.instance.Binding binding) |
protected boolean |
allowedToComputeNewBinding() |
protected void |
delayEmission() |
java.lang.Class<XSEvent> |
getTopic() |
protected org.deckfour.xes.model.XAttribute |
identifyCase(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding) |
protected void |
initializeSimulator() |
protected boolean |
mayEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding) |
protected void |
processAndEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding) |
protected void |
workPackage() |
getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
connect, disconnect, getNumberOfPacketsSend, getWritables, run, write
isPaused, isRunning, isStarted, isStopped
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
protected final org.cpntools.accesscpn.model.PetriNet pn
protected final org.cpntools.accesscpn.engine.highlevel.instance.State initialState
protected final org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator simulator
protected final CPN2XSEventStreamParameters parameters
protected java.math.BigInteger lastStep
protected final org.deckfour.xes.factory.XFactory xfact
protected long currentStep
protected int currentRepetition
protected long lastSend
protected final long waitTimeNs
public CPNModelToXSEventStreamAuthorImpl(org.cpntools.accesscpn.model.PetriNet pn, org.cpntools.accesscpn.engine.highlevel.instance.State iState, org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator sim, CPN2XSEventStreamParameters parameters)
protected void workPackage()
workPackage
in class org.processmining.stream.core.abstracts.AbstractXSRunnable
protected boolean allowedToComputeNewBinding()
protected boolean mayEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void processAndEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void delayEmission()
protected XSEvent addData(XSEvent event, org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected org.deckfour.xes.model.XAttribute identifyCase(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void initializeSimulator()
public java.lang.Class<XSEvent> getTopic()