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> SingleOutputStreamOperator<Map<String,List<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> SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<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 | Method and Description |
---|---|
Pattern<T,F> |
Pattern.allowCombinations()
Applicable only to
Quantifier.ONE_OR_MORE(ConsumingStrategy) and
Quantifier.TIMES(ConsumingStrategy) patterns, this option allows more flexibility to the matching events. |
static <X> Pattern<X,X> |
Pattern.begin(String name)
Starts a new pattern sequence.
|
Pattern<T,F> |
Pattern.consecutive()
Works in conjunction with
oneOrMore() or times(int) . |
Pattern<T,T> |
Pattern.followedBy(String name)
Appends a new pattern to the existing one.
|
Pattern<T,T> |
Pattern.followedByAny(String name)
Appends a new pattern to the existing one.
|
Pattern<T,? extends T> |
Pattern.getPrevious() |
Pattern<T,T> |
Pattern.next(String name)
Appends a new pattern to the existing one.
|
Pattern<T,T> |
Pattern.notFollowedBy(String name)
Appends a new pattern to the existing one.
|
Pattern<T,T> |
Pattern.notNext(String name)
Appends a new pattern to the existing one.
|
Pattern<T,F> |
Pattern.oneOrMore()
Specifies that this pattern can occur
one or more times. |
Pattern<T,F> |
Pattern.optional()
Specifies that this pattern is optional for a final match of the pattern
sequence to happen.
|
Pattern<T,F> |
Pattern.or(IterativeCondition<F> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
<S extends F> |
Pattern.subtype(Class<S> subtypeClass)
Applies a subtype constraint on the current pattern.
|
Pattern<T,F> |
Pattern.times(int times)
Specifies exact number of times that this pattern should be matched.
|
Pattern<T,F> |
Pattern.where(IterativeCondition<F> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
Pattern<T,F> |
Pattern.within(Time windowTime)
Defines the maximum time interval in which a matching pattern has to be completed in
order to be considered valid.
|
Constructor and Description |
---|
Pattern(String name,
Pattern<T,? extends T> previous) |
Pattern(String name,
Pattern<T,? extends T> previous,
Quantifier.ConsumingStrategy consumingStrategy) |
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–2018 The Apache Software Foundation. All rights reserved.