Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.nfa.compiler |
Modifier and Type | Method and Description |
---|---|
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from) |
NFA<T> |
NFA.NFASerializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.NFASerializer.createInstance() |
NFA<T> |
NFA.NFASerializer.deserialize(DataInputView source) |
NFA<T> |
NFA.NFASerializer.deserialize(NFA<T> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
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.NFASerializer.copy(NFA<T> from,
NFA<T> reuse) |
NFA<T> |
NFA.NFASerializer.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) |
void |
NFA.NFASerializer.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() |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.