Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.scala |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Creates a
PatternStream from an input data stream and a pattern. |
Modifier and Type | Method and Description |
---|---|
PatternStream<T> |
PatternStream.wrappedPatternStream() |
Modifier and Type | Method and Description |
---|---|
<T> PatternStream<T> |
PatternStream$.apply(PatternStream<T> jPatternStream) |
static <T> PatternStream<T> |
PatternStream.apply(PatternStream<T> jPatternStream) |
Constructor and Description |
---|
PatternStream(PatternStream<T> jPatternStream) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.