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)
Creates a
PatternStream from an input data stream and a pattern. |
public static <T> PatternStream<T> pattern(DataStream<T> input, Pattern<T,?> pattern)
PatternStream
from an input data stream and a pattern.T
- Type of the input eventsinput
- DataStream containing the input eventspattern
- Pattern specification which shall be detectedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.