Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.functions.adaptors | |
org.apache.flink.cep.operator | |
org.apache.flink.table.runtime.operators.match |
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
PatternStream.process(PatternProcessFunction<T,R> patternProcessFunction)
Applies a process function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.process(PatternProcessFunction<T,R> patternProcessFunction,
TypeInformation<R> outTypeInfo)
Applies a process function to the detected pattern sequence.
|
Modifier and Type | Class and Description |
---|---|
class |
PatternFlatSelectAdapter<IN,OUT>
Adapter that expresses
PatternFlatSelectFunction with PatternProcessFunction . |
class |
PatternSelectAdapter<IN,OUT>
Adapter that expresses
PatternSelectFunction with PatternProcessFunction . |
class |
PatternTimeoutFlatSelectAdapter<IN,OUT,T>
Adapter that expresses combination of
PatternFlatSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction . |
class |
PatternTimeoutSelectAdapter<IN,OUT,T>
Adapter that expresses combination of
PatternSelectFunction and PatternTimeoutFlatSelectAdapter with PatternProcessFunction . |
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 |
PatternProcessFunctionRunner
A
PatternProcessFunction wrapper to delegate invocation to the code generated PatternProcessFunction . |
Constructor and Description |
---|
PatternProcessFunctionRunner(GeneratedFunction<PatternProcessFunction<RowData,RowData>> generatedFunction) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.