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 and 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 AfterMatchSkipStrategy in org.apache.flink.cep.nfa.aftermatch

Subclasses of AfterMatchSkipStrategy in org.apache.flink.cep.nfa.aftermatch

Modifier and Type	Class and Description
class	NoSkipStrategy Every possible match will be emitted.
class	SkipPastLastStrategy Discards every partial match that started before emitted match ended.
class	SkipToFirstStrategy Discards every partial match that started before the first event of emitted match mapped to *PatternName*.
class	SkipToLastStrategy Discards every partial match that started before the last event of emitted match mapped to *PatternName*.
class	SkipToNextStrategy Discards 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 and Description
static AfterMatchSkipStrategy	AfterMatchSkipStrategy.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 and Description
CepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy afterMatchSkipStrategy, PatternProcessFunction<IN,OUT> function, 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 and Description
AfterMatchSkipStrategy	Pattern.getAfterMatchSkipStrategy()

Methods in org.apache.flink.cep.pattern with parameters of type AfterMatchSkipStrategy

Modifier and Type	Method and Description
static <T,F extends T> GroupPattern<T,F>	Pattern.begin(Pattern<T,F> group, AfterMatchSkipStrategy afterMatchSkipStrategy) Starts a new pattern sequence.
static <X> Pattern<X,X>	Pattern.begin(String name, AfterMatchSkipStrategy afterMatchSkipStrategy) Starts a new pattern sequence.

Constructors in org.apache.flink.cep.pattern with parameters of type AfterMatchSkipStrategy

Constructor and Description
Pattern(String name, Pattern<T,? extends T> previous, Quantifier.ConsumingStrategy consumingStrategy, AfterMatchSkipStrategy afterMatchSkipStrategy)