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 booleanequals(Object o)Queue<ComputationState>getCompletedMatches()Queue<ComputationState>getPartialMatches()inthashCode()booleanisNewStartPartialMatch()booleanisStateChanged()Check if the matching status of the NFA has changed so far.voidresetNewStartPartialMatch()voidresetStateChanged()Reset the changed bit checked viaisStateChanged()tofalse.voidsetNewPartialMatches(PriorityQueue<ComputationState> newPartialMatches)voidsetNewStartPartiailMatch()voidsetStateChanged()Set the changed bit checked viaisStateChanged()totrue.StringtoString()
-
-
-
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:
trueif matching status has changed,falseotherwise
-
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()
-
-