Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.nfa.compiler | |
org.apache.flink.cep.operator | |
org.apache.flink.cep.pattern | |
org.apache.flink.cep.scala.pattern |
Modifier and Type | Method and Description |
---|---|
Pattern<T,?> |
PatternStream.getPattern() |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Creates a
PatternStream from an input data stream and a pattern. |
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 . |
static <T> NFACompiler.NFAFactory<T> |
NFACompiler.compileFactory(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer,
boolean timeoutHandling)
Compiles the given pattern into a
NFACompiler.NFAFactory . |
Modifier and Type | Method and Description |
---|---|
static <K,T> DataStream<Map<String,T>> |
CEPOperatorUtils.createPatternStream(DataStream<T> inputStream,
Pattern<T,?> pattern)
Creates a data stream containing the fully matching event patterns of the NFA computation.
|
static <K,T> DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> |
CEPOperatorUtils.createTimeoutPatternStream(DataStream<T> inputStream,
Pattern<T,?> pattern)
Creates a data stream containing fully matching event patterns or partially matching event
patterns which have timed out.
|
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,? extends 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,? extends T> previous) |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.wrappedPattern() |
Modifier and Type | Method and Description |
---|---|
<T,F extends T> |
Pattern$.apply(Pattern<T,F> jPattern)
Constructs a new Pattern by wrapping a given Java API Pattern
|
static <T,F extends T> |
Pattern.apply(Pattern<T,F> jPattern)
Constructs a new Pattern by wrapping a given Java API Pattern
|
Constructor and Description |
---|
Pattern(Pattern<T,F> jPattern) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.