Package | Description |
---|---|
org.apache.flink.cep.scala | |
org.apache.flink.cep.scala.pattern |
Modifier and Type | Method and Description |
---|---|
Pattern<T,T> |
PatternStream.getPattern() |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
<T> PatternStream<T> |
CEP$.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.allowCombinations()
Applicable only to
Quantifier.ONE_OR_MORE() and Quantifier.TIMES() patterns,
this option allows more flexibility to the matching events. |
<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
|
<X> Pattern<X,X> |
Pattern$.begin(String name)
Starts a new pattern sequence.
|
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,T> |
Pattern.next(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
|
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(scala.Function1<F,Object> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
Pattern<T,F> |
Pattern.or(scala.Function2<F,Context<F>,Object> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
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> clazz)
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(scala.Function1<F,Object> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
Pattern<T,F> |
Pattern.where(scala.Function2<F,Context<F>,Object> condition)
Adds a condition that has to be satisfied by an event
in order to be considered a match.
|
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.
|
Modifier and Type | Method and Description |
---|---|
scala.Option<Pattern<T,? extends T>> |
Pattern.getPrevious() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.