Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.aftermatch |
Modifier and Type | Field and Description |
---|---|
static Comparator<ComputationState> |
NFAState.COMPUTATION_STATE_COMPARATOR |
Modifier and Type | Method and Description |
---|---|
static ComputationState |
ComputationState.createStartState(String state) |
static ComputationState |
ComputationState.createStartState(String state,
DeweyNumber version) |
static ComputationState |
ComputationState.createState(String currentState,
NodeId previousEntry,
DeweyNumber version,
long startTimestamp,
EventId startEventID) |
Modifier and Type | Method and Description |
---|---|
Queue<ComputationState> |
NFAState.getCompletedMatches() |
Queue<ComputationState> |
NFA.MigratedNFA.getComputationStates() |
Queue<ComputationState> |
NFAState.getPartialMatches() |
Modifier and Type | Method and Description |
---|---|
void |
NFAState.setNewPartialMatches(PriorityQueue<ComputationState> newPartialMatches) |
Constructor and Description |
---|
NFAState(Iterable<ComputationState> states) |
NFAState(Queue<ComputationState> partialMatches,
Queue<ComputationState> completedMatches) |
NFAState(Queue<ComputationState> partialMatches,
Queue<ComputationState> completedMatches) |
Modifier and Type | Method and Description |
---|---|
void |
AfterMatchSkipStrategy.prune(Collection<ComputationState> matchesToPrune,
Collection<Map<String,List<EventId>>> matchedResult,
SharedBufferAccessor<?> sharedBufferAccessor)
Prunes matches/partial matches based on the chosen strategy.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.