Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.compiler | |
org.apache.flink.cep.operator |
Modifier and Type | Method and Description |
---|---|
NFA<T> |
NFA.Serializer.copy(NFA<T> from) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.createInstance() |
NFA<T> |
NFA.Serializer.deserialize(DataInputView source) |
NFA<T> |
NFA.Serializer.deserialize(NFA<T> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<NFA<T>> |
NFA.Serializer.duplicate() |
Modifier and Type | Method and Description |
---|---|
NFA<T> |
NFA.Serializer.copy(NFA<T> from) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.deserialize(NFA<T> reuse,
DataInputView source) |
void |
NFA.Serializer.serialize(NFA<T> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
static <T> NFA<T> |
NFACompiler.compile(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer,
boolean timeoutHandling)
Compiles the given pattern into a
NFA . |
NFA<T> |
NFACompiler.NFAFactory.createNFA() |
Modifier and Type | Method and Description |
---|---|
protected NFA<IN> |
AbstractKeyedCEPPatternOperator.getNFA() |
protected NFA<IN> |
AbstractCEPPatternOperator.getNFA() |
protected abstract NFA<IN> |
AbstractCEPBasePatternOperator.getNFA() |
Modifier and Type | Method and Description |
---|---|
protected void |
TimeoutKeyedCEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected void |
TimeoutCEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected void |
KeyedCEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected void |
CEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected abstract void |
AbstractCEPBasePatternOperator.advanceTime(NFA<IN> nfa,
long timestamp)
Advances the time for the given NFA to the given timestamp.
|
protected void |
TimeoutKeyedCEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp) |
protected void |
TimeoutCEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp) |
protected void |
KeyedCEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp) |
protected void |
CEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp) |
protected abstract void |
AbstractCEPBasePatternOperator.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.
|
protected void |
AbstractKeyedCEPPatternOperator.updateNFA(NFA<IN> nfa) |
protected void |
AbstractCEPPatternOperator.updateNFA(NFA<IN> nfa) |
protected abstract void |
AbstractCEPBasePatternOperator.updateNFA(NFA<IN> nfa) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.