Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.aftermatch |
Modifier and Type | Method and Description |
---|---|
Collection<Tuple2<Map<String,List<T>>,Long>> |
NFA.advanceTime(SharedBuffer<T> sharedBuffer,
NFAState nfaState,
long timestamp)
Prunes states assuming there will be no events with timestamp lower than the given one.
|
Collection<Map<String,List<T>>> |
NFA.process(SharedBuffer<T> sharedBuffer,
NFAState nfaState,
T event,
long timestamp)
Processes the next input event.
|
Collection<Map<String,List<T>>> |
NFA.process(SharedBuffer<T> sharedBuffer,
NFAState nfaState,
T event,
long timestamp,
AfterMatchSkipStrategy afterMatchSkipStrategy)
Processes the next input event.
|
Modifier and Type | Method and Description |
---|---|
void |
AfterMatchSkipStrategy.prune(Collection<ComputationState> matchesToPrune,
Collection<Map<String,List<EventId>>> matchedResult,
SharedBuffer<?> sharedBuffer)
Prunes matches/partial matches based on the chosen strategy.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.