Package org.apache.flink.cep.nfa
Class NFAState
- java.lang.Object
-
- org.apache.flink.cep.nfa.NFAState
-
-
Field Summary
Fields Modifier and Type Field Description static Comparator<ComputationState>
COMPUTATION_STATE_COMPARATOR
-
Constructor Summary
Constructors Constructor Description NFAState(Iterable<ComputationState> states)
NFAState(Queue<ComputationState> partialMatches, Queue<ComputationState> completedMatches)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
Queue<ComputationState>
getCompletedMatches()
Queue<ComputationState>
getPartialMatches()
int
hashCode()
boolean
isNewStartPartialMatch()
boolean
isStateChanged()
Check if the matching status of the NFA has changed so far.void
resetNewStartPartialMatch()
void
resetStateChanged()
Reset the changed bit checked viaisStateChanged()
tofalse
.void
setNewPartialMatches(PriorityQueue<ComputationState> newPartialMatches)
void
setNewStartPartiailMatch()
void
setStateChanged()
Set the changed bit checked viaisStateChanged()
totrue
.String
toString()
-
-
-
Field Detail
-
COMPUTATION_STATE_COMPARATOR
public static final Comparator<ComputationState> COMPUTATION_STATE_COMPARATOR
-
-
Constructor Detail
-
NFAState
public NFAState(Iterable<ComputationState> states)
-
NFAState
public NFAState(Queue<ComputationState> partialMatches, Queue<ComputationState> completedMatches)
-
-
Method Detail
-
isStateChanged
public boolean isStateChanged()
Check if the matching status of the NFA has changed so far.- Returns:
true
if matching status has changed,false
otherwise
-
resetStateChanged
public void resetStateChanged()
Reset the changed bit checked viaisStateChanged()
tofalse
.
-
setStateChanged
public void setStateChanged()
Set the changed bit checked viaisStateChanged()
totrue
.
-
getPartialMatches
public Queue<ComputationState> getPartialMatches()
-
getCompletedMatches
public Queue<ComputationState> getCompletedMatches()
-
setNewPartialMatches
public void setNewPartialMatches(PriorityQueue<ComputationState> newPartialMatches)
-
isNewStartPartialMatch
public boolean isNewStartPartialMatch()
-
resetNewStartPartialMatch
public void resetNewStartPartialMatch()
-
setNewStartPartiailMatch
public void setNewStartPartiailMatch()
-
-