Package | Description |
---|---|
org.apache.flink.cep.nfa.compiler | |
org.apache.flink.cep.operator |
Modifier and Type | Method and Description |
---|---|
static <T> NFA<T> |
NFACompiler.compile(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer)
Compiles the given pattern into a
NFA . |
NFA<T> |
NFACompiler.NFAFactory.createNFA() |
Modifier and Type | Method and Description |
---|---|
protected NFA<IN> |
KeyedCEPPatternOperator.getNFA() |
protected abstract NFA<IN> |
AbstractCEPPatternOperator.getNFA() |
protected NFA<IN> |
CEPPatternOperator.getNFA() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractCEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp)
Process the given event by giving it to the NFA and outputting the produced set of matched
event sequences.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.