org.apache.flink.cep.nfa

Class ComputationState

java.lang.Object

org.apache.flink.cep.nfa.ComputationState

public class ComputationState
extends Object

Helper class which encapsulates the currentStateName of the NFA computation. It points to the current currentStateName, the previous entry of the pattern, the current version and the starting timestamp of the overall pattern.

Method Summary

Modifier and Type	Method and Description
static ComputationState	createStartState(String state)
static ComputationState	createStartState(String state, DeweyNumber version)
static ComputationState	createState(String currentState, NodeId previousEntry, DeweyNumber version, long startTimestamp, EventId startEventID)
boolean	equals(Object obj)
String	getCurrentStateName()
NodeId	getPreviousBufferEntry()
EventId	getStartEventID()
long	getStartTimestamp()
DeweyNumber	getVersion()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getStartEventID

public EventId getStartEventID()

getPreviousBufferEntry

public NodeId getPreviousBufferEntry()

getStartTimestamp

public long getStartTimestamp()

getCurrentStateName

public String getCurrentStateName()

getVersion

public DeweyNumber getVersion()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

createStartState

public static ComputationState createStartState(String state)

createStartState

public static ComputationState createStartState(String state,
                                                DeweyNumber version)

createState

public static ComputationState createState(String currentState,
                                           NodeId previousEntry,
                                           DeweyNumber version,
                                           long startTimestamp,
                                           EventId startEventID)