public class StreamFlowerDiscoveryAlgorithmImpl extends AbstractXSEventReader<org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,StreamFlowerDiscoveryAlgorithmParametersImpl> implements XSEventStreamToAcceptingPetriNetReader
Modifier and Type | Field and Description |
---|---|
static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type> |
ALLOWED_DATA_STRUCTURES |
Constructor and Description |
---|
StreamFlowerDiscoveryAlgorithmImpl(org.processmining.framework.plugin.PluginContext context,
StreamFlowerDiscoveryAlgorithmParametersImpl parameters) |
Modifier and Type | Method and Description |
---|---|
protected org.processmining.acceptingpetrinet.models.AcceptingPetriNet |
computeCurrentResult() |
void |
processNewXSEvent(java.lang.String caseId,
org.deckfour.xes.classification.XEventClass activity) |
void |
startXSRunnable() |
canReadPacket, findEventIdentifierIndex, getActivity, getEventClasses, getParameters, getTopic, getVisualization, handleNextPacket, measureUsedMemory, setEventClasses, setVisualization
getCurrentResult, interrupt, pause, pauseXSRunnable, start, stopXSRunnable
deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, 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, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, stop, stopXSRunnable
deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle
public static java.util.Collection<org.processmining.stream.model.datastructure.DataStructure.Type> ALLOWED_DATA_STRUCTURES
public StreamFlowerDiscoveryAlgorithmImpl(org.processmining.framework.plugin.PluginContext context, StreamFlowerDiscoveryAlgorithmParametersImpl parameters)
public void startXSRunnable()
startXSRunnable
in interface org.processmining.stream.core.interfaces.XSRunnable
startXSRunnable
in class org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet>
public void processNewXSEvent(java.lang.String caseId, org.deckfour.xes.classification.XEventClass activity)
processNewXSEvent
in class AbstractXSEventReader<org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,StreamFlowerDiscoveryAlgorithmParametersImpl>
protected org.processmining.acceptingpetrinet.models.AcceptingPetriNet computeCurrentResult()
computeCurrentResult
in class org.processmining.stream.core.abstracts.AbstractXSReader<XSEvent,org.processmining.acceptingpetrinet.models.AcceptingPetriNet,org.processmining.acceptingpetrinet.models.AcceptingPetriNet>