Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.operator | |
org.apache.flink.table.runtime.operators.match |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern,
EventComparator<T> comparator)
Creates a
PatternStream from an input data stream and a pattern. |
Constructor and Description |
---|
CepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy afterMatchSkipStrategy,
PatternProcessFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
Modifier and Type | Class and Description |
---|---|
class |
BaseRowEventComparator
An implementation of
EventComparator based on a generated RecordComparator . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.