Uses of Class
org.apache.flink.cep.nfa.sharedbuffer.SharedBufferAccessor
-
Packages that use SharedBufferAccessor Package Description org.apache.flink.cep.nfa org.apache.flink.cep.nfa.aftermatch org.apache.flink.cep.nfa.sharedbuffer -
-
Uses of SharedBufferAccessor in org.apache.flink.cep.nfa
Methods in org.apache.flink.cep.nfa with parameters of type SharedBufferAccessor Modifier and Type Method Description Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>>
NFA. advanceTime(SharedBufferAccessor<T> sharedBufferAccessor, NFAState nfaState, long timestamp, AfterMatchSkipStrategy afterMatchSkipStrategy)
Prunes states assuming there will be no events with timestamp lower than the given one.Collection<Map<String,List<T>>>
NFA. process(SharedBufferAccessor<T> sharedBufferAccessor, NFAState nfaState, T event, long timestamp, AfterMatchSkipStrategy afterMatchSkipStrategy, TimerService timerService)
Processes the next input event. -
Uses of SharedBufferAccessor in org.apache.flink.cep.nfa.aftermatch
Methods in org.apache.flink.cep.nfa.aftermatch with parameters of type SharedBufferAccessor Modifier and Type Method Description void
AfterMatchSkipStrategy. prune(Collection<ComputationState> matchesToPrune, Collection<Map<String,List<EventId>>> matchedResult, SharedBufferAccessor<?> sharedBufferAccessor)
Prunes matches/partial matches based on the chosen strategy. -
Uses of SharedBufferAccessor in org.apache.flink.cep.nfa.sharedbuffer
Methods in org.apache.flink.cep.nfa.sharedbuffer that return SharedBufferAccessor Modifier and Type Method Description SharedBufferAccessor<V>
SharedBuffer. getAccessor()
Construct an accessor to deal with this sharedBuffer.
-