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 |
---|---|
<T> PatternStream<T> |
CEP$.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
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 <T,F extends T> |
Pattern.apply(Pattern<T,F> jPattern)
Constructs a new Pattern by wrapping a given Java API Pattern
|
<T,F extends T> |
Pattern$.apply(Pattern<T,F> jPattern)
Constructs a new Pattern by wrapping a given Java API Pattern
|
static <X> Pattern<X,X> |
Pattern.begin(String name)
Starts a new pattern with the initial pattern operator whose name is provided.
|
<X> Pattern<X,X> |
Pattern$.begin(String name)
Starts a new pattern with the initial pattern operator whose name is provided.
|
Pattern<T,T> |
Pattern.next(String name)
Appends a new pattern operator to the existing one.
|
Pattern<T,F> |
Pattern.or(FilterFunction<F> filter)
Specifies a filter condition which is ORed with an existing filter function.
|
<S extends F> |
Pattern.subtype(Class<S> clazz)
Applies a subtype constraint on the current pattern operator.
|
Pattern<T,F> |
Pattern.where(FilterFunction<F> filter)
Specifies a filter condition which has to be fulfilled by an event in order to be matched.
|
Pattern<T,F> |
Pattern.where(scala.Function1<F,Object> filterFun)
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.
|
Modifier and Type | Method and Description |
---|---|
scala.Option<Pattern<T,? extends T>> |
Pattern.getPrevious() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.