Uses of Class
org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy
-
Packages that use AfterMatchSkipStrategy Package Description org.apache.flink.cep.nfa org.apache.flink.cep.nfa.aftermatch org.apache.flink.cep.operator org.apache.flink.cep.pattern -
-
Uses of AfterMatchSkipStrategy in org.apache.flink.cep.nfa
Methods in org.apache.flink.cep.nfa with parameters of type AfterMatchSkipStrategy Modifier and Type Method Description org.apache.flink.api.java.tuple.Tuple2<Collection<Map<String,List<T>>>,Collection<org.apache.flink.api.java.tuple.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 AfterMatchSkipStrategy in org.apache.flink.cep.nfa.aftermatch
Subclasses of AfterMatchSkipStrategy in org.apache.flink.cep.nfa.aftermatch Modifier and Type Class Description classNoSkipStrategyEvery possible match will be emitted.classSkipPastLastStrategyDiscards every partial match that started before emitted match ended.classSkipToFirstStrategyDiscards every partial match that started before the first event of emitted match mapped to *PatternName*.classSkipToLastStrategyDiscards every partial match that started before the last event of emitted match mapped to *PatternName*.classSkipToNextStrategyDiscards every partial match that started with the same event, emitted match was started.Methods in org.apache.flink.cep.nfa.aftermatch that return AfterMatchSkipStrategy Modifier and Type Method Description static AfterMatchSkipStrategyAfterMatchSkipStrategy. skipToNext()Discards every partial match that started with the same event, emitted match was started. -
Uses of AfterMatchSkipStrategy in org.apache.flink.cep.operator
Constructors in org.apache.flink.cep.operator with parameters of type AfterMatchSkipStrategy Constructor Description CepOperator(org.apache.flink.api.common.typeutils.TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy afterMatchSkipStrategy, PatternProcessFunction<IN,OUT> function, org.apache.flink.util.OutputTag<IN> lateDataOutputTag) -
Uses of AfterMatchSkipStrategy in org.apache.flink.cep.pattern
Methods in org.apache.flink.cep.pattern that return AfterMatchSkipStrategy Modifier and Type Method Description AfterMatchSkipStrategyPattern. getAfterMatchSkipStrategy()Methods in org.apache.flink.cep.pattern with parameters of type AfterMatchSkipStrategy Modifier and Type Method Description static <X> Pattern<X,X>Pattern. begin(String name, AfterMatchSkipStrategy afterMatchSkipStrategy)Starts a new pattern sequence.static <T,F extends T>
GroupPattern<T,F>Pattern. begin(Pattern<T,F> group, AfterMatchSkipStrategy afterMatchSkipStrategy)Starts a new pattern sequence.Constructors in org.apache.flink.cep.pattern with parameters of type AfterMatchSkipStrategy Constructor Description Pattern(String name, Pattern<T,? extends T> previous, Quantifier.ConsumingStrategy consumingStrategy, AfterMatchSkipStrategy afterMatchSkipStrategy)
-