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.NFASerializer.copy(NFA<T> from) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from) |
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.NFASerializer.createInstance() |
NFA<T> |
NFA.Serializer.createInstance() |
NFA<T> |
NFA.NFASerializer.deserialize(DataInputView source) |
NFA<T> |
NFA.Serializer.deserialize(DataInputView source) |
NFA<T> |
NFA.NFASerializer.deserialize(NFA<T> reuse,
DataInputView source) |
NFA<T> |
NFA.Serializer.deserialize(NFA<T> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<NFA<T>> |
NFA.NFASerializer.duplicate() |
CompatibilityResult<NFA<T>> |
NFA.NFASerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from) |
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.Serializer.copy(NFA<T> from,
NFA<T> reuse) |
static <T> ComputationState<T> |
ComputationState.createStartState(NFA<T> nfa,
State<T> state) |
static <T> ComputationState<T> |
ComputationState.createStartState(NFA<T> nfa,
State<T> state,
DeweyNumber version) |
static <T> ComputationState<T> |
ComputationState.createState(NFA<T> nfa,
State<T> currentState,
State<T> previousState,
T event,
int counter,
long timestamp,
DeweyNumber version,
long startTimestamp) |
NFA<T> |
NFA.NFASerializer.deserialize(NFA<T> reuse,
DataInputView source) |
NFA<T> |
NFA.Serializer.deserialize(NFA<T> reuse,
DataInputView source) |
void |
NFA.NFASerializer.serialize(NFA<T> record,
DataOutputView target) |
void |
NFA.Serializer.serialize(NFA<T> record,
DataOutputView target) |
Constructor and Description |
---|
ConditionContext(NFA<T> nfa,
ComputationState<T> computationState) |
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 void |
TimeoutKeyedCEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected void |
KeyedCEPPatternOperator.advanceTime(NFA<IN> nfa,
long timestamp) |
protected abstract void |
AbstractKeyedCEPPatternOperator.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 |
KeyedCEPPatternOperator.processEvent(NFA<IN> nfa,
IN event,
long timestamp) |
protected abstract void |
AbstractKeyedCEPPatternOperator.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–2018 The Apache Software Foundation. All rights reserved.