Package | Description |
---|---|
org.apache.flink.cep |
Modifier and Type | Method and Description |
---|---|
static <T,K> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Transforms a
DataStream into a PatternStream . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.