public abstract class OnlineDeclareMiner
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected org.processmining.operationalsupport.xml.OSXMLConverter |
converter |
protected int |
eventsReceived |
protected int |
modelUpdateFrequency |
protected org.apache.commons.lang3.time.StopWatch |
timer |
| Constructor and Description |
|---|
OnlineDeclareMiner(java.lang.String minerName)
Class constructor
|
| Modifier and Type | Method and Description |
|---|---|
int |
getEventsReceived()
This method returns the number of events received so far
|
java.lang.String |
getMinerName()
This method returns the name of the current miner
|
int |
getModelUpdateFrequency()
This method returns the update frequency of the model
|
abstract java.lang.Integer |
getSize()
This method returns the size of the current miner
|
org.apache.commons.lang3.time.StopWatch |
getTimer()
This method returns the timer object
|
abstract DeclareModel |
processEvent(java.lang.String streamLine)
This method is responsible for processing the provided stream line in the
current Declare miner
|
void |
setModelUpdateFrequency(int modelUpdateFrequency)
This method sets the update frequency of the model
|
protected int modelUpdateFrequency
protected org.apache.commons.lang3.time.StopWatch timer
protected int eventsReceived
protected org.processmining.operationalsupport.xml.OSXMLConverter converter
public OnlineDeclareMiner(java.lang.String minerName)
minerName - the name to assign to the current Declare minerpublic abstract DeclareModel processEvent(java.lang.String streamLine)
streamLine - the stream line receivedpublic abstract java.lang.Integer getSize()
public int getModelUpdateFrequency()
public void setModelUpdateFrequency(int modelUpdateFrequency)
modelUpdateFrequency - the model update frequencypublic org.apache.commons.lang3.time.StopWatch getTimer()
public java.lang.String getMinerName()
public int getEventsReceived()