public class CEP extends Object
DataStream
into a PatternStream
to do CEP.Constructor and Description |
---|
CEP() |
Modifier and Type | Method and Description |
---|---|
static <T,K> PatternStream<T> |
pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream . |
public static <T,K> PatternStream<T> pattern(DataStream<T> input, Pattern<T,?> pattern)
DataStream
into a PatternStream
. The PatternStream detects
the provided event pattern and emits the patterns as a Map
where each event
is identified by a String. The String is the name of the
to which the event
has been associated.
Depending on the input DataStream
type, keyed vs. non-keyed, a different
org.apache.flink.cep.operator.AbstractCEPPatternOperator
is instantiated.T
- Type of the input eventsK
- Type of the key in case of a KeyedStream (necessary to bind keySelector and
keySerializer to the same type)input
- DataStream containing the input eventspattern
- Pattern specification which shall be detectedCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.