Package | Description |
---|---|
org.apache.flink.cep.scala |
Modifier and Type | Method and Description |
---|---|
<T> PatternStream<T> |
PatternStream$.apply(PatternStream<T> jPatternStream) |
static <T> PatternStream<T> |
PatternStream.apply(PatternStream<T> jPatternStream) |
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
<T> PatternStream<T> |
CEP$.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream in the Scala API. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.