public class CEP$ extends Object
DataStream
into a PatternStream
to do CEP.Modifier and Type | Field and Description |
---|---|
static CEP$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
CEP$() |
Modifier and Type | Method and Description |
---|---|
<T> PatternStream<T> |
pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
public static final CEP$ MODULE$
public <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–2018 The Apache Software Foundation. All rights reserved.