Package org.apache.flink.cep.nfa

Class State<T>

java.lang.Object

org.apache.flink.cep.nfa.State<T>

Type Parameters:

T - Type of the input events

All Implemented Interfaces:

Serializable

public class State<T>
extends Object
implements Serializable

Represents a state of the NFA.

Each state is identified by a name and a state type. Furthermore, it contains a collection of state transitions. The state transitions describe under which conditions it is possible to enter a new state.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	State.StateType	Set of valid state types.

Constructor Summary

Constructors

Constructor	Description
State(String name, State.StateType stateType)

Method Summary

Modifier and Type	Method	Description
void	addIgnore(State<T> targetState, IterativeCondition<T> condition)
void	addIgnore(IterativeCondition<T> condition)
void	addProceed(State<T> targetState, IterativeCondition<T> condition)
void	addStateTransition(StateTransitionAction action, State<T> targetState, IterativeCondition<T> condition)
void	addTake(State<T> targetState, IterativeCondition<T> condition)
void	addTake(IterativeCondition<T> condition)
boolean	equals(Object obj)
String	getName()
Collection<StateTransition<T>>	getStateTransitions()
State.StateType	getStateType()
int	hashCode()
boolean	isFinal()
boolean	isPending()
boolean	isStart()
boolean	isStop()
void	makeStart()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

State

public State(String name,
             State.StateType stateType)

Method Detail

getStateType

public State.StateType getStateType()

isFinal

public boolean isFinal()

isStart

public boolean isStart()

getName

public String getName()

getStateTransitions

public Collection<StateTransition<T>> getStateTransitions()

makeStart

public void makeStart()

addStateTransition

public void addStateTransition(StateTransitionAction action,
                               State<T> targetState,
                               IterativeCondition<T> condition)

addIgnore

public void addIgnore(IterativeCondition<T> condition)

addIgnore

public void addIgnore(State<T> targetState,
                      IterativeCondition<T> condition)

addTake

public void addTake(State<T> targetState,
                    IterativeCondition<T> condition)

addProceed

public void addProceed(State<T> targetState,
                       IterativeCondition<T> condition)

addTake

public void addTake(IterativeCondition<T> condition)

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

isStop

public boolean isStop()

isPending

public boolean isPending()