public class CEP extends Object
DataStream
into a PatternStream
to do CEP.Constructor and Description |
---|
CEP() |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
public static <T> PatternStream<T> pattern(DataStream<T> input, Pattern<T,?> pattern)
DataStream
into a PatternStream
in the Scala API.
See CEP
}for a more detailed description how the underlying
Java API works.
input
- DataStream containing the input eventspattern
- Pattern specification which shall be detectedCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.