Package | Description |
---|---|
org.apache.flink.cep.nfa.compiler | |
org.apache.flink.cep.operator |
Modifier and Type | Method and Description |
---|---|
static <T> NFACompiler.NFAFactory<T> |
NFACompiler.compileFactory(Pattern<T,?> pattern,
boolean timeoutHandling)
Compiles the given pattern into a
NFACompiler.NFAFactory . |
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) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.