Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.nfa.compiler | |
org.apache.flink.cep.pattern |
Modifier and Type | Method and Description |
---|---|
static <T,K> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream . |
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 . |
static <T> NFACompiler.NFAFactory<T> |
NFACompiler.compileFactory(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer)
Compiles the given pattern into a
NFACompiler.NFAFactory . |
Modifier and Type | Class and Description |
---|---|
class |
FollowedByPattern<T,F extends T>
Pattern operator which signifies that the there is a non-strict temporal contiguity between
itself and its preceding pattern operator.
|
Modifier and Type | Method and Description |
---|---|
static <X> Pattern<X,X> |
Pattern.begin(String name)
Starts a new pattern with the initial pattern operator whose name is provided.
|
Pattern<T,?> |
Pattern.getPrevious() |
Pattern<T,T> |
Pattern.next(String name)
Appends a new pattern operator to the existing one.
|
<S extends F> |
Pattern.subtype(Class<S> subtypeClass)
Applies a subtype constraint on the current pattern operator.
|
Pattern<T,F> |
Pattern.where(FilterFunction<F> newFilterFunction)
Specifies a filter condition which has to be fulfilled by an event in order to be matched.
|
Pattern<T,F> |
Pattern.within(Time windowTime)
Defines the maximum time interval for a matching pattern.
|
Constructor and Description |
---|
Pattern(String name,
Pattern<T,?> previous) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.