Uses of Interface
org.apache.flink.cep.EventComparator

Packages that use EventComparator

Package	Description
org.apache.flink.cep
org.apache.flink.cep.operator

Uses of EventComparator in org.apache.flink.cep

Methods in org.apache.flink.cep that return EventComparator

Modifier and Type	Method and Description
EventComparator<T>	PatternStream.getComparator()

Methods in org.apache.flink.cep with parameters of type EventComparator

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.

Uses of EventComparator in org.apache.flink.cep.operator

Methods in org.apache.flink.cep.operator with parameters of type EventComparator

Modifier and Type	Method and Description
static <IN,OUT> SingleOutputStreamOperator<OUT>	CEPOperatorUtils.createPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternFlatSelectFunction<IN,OUT> selectFunction, TypeInformation<OUT> outTypeInfo) Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns.
static <IN,OUT> SingleOutputStreamOperator<OUT>	CEPOperatorUtils.createPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternSelectFunction<IN,OUT> selectFunction, TypeInformation<OUT> outTypeInfo) Creates a data stream containing results of PatternSelectFunction to fully matching event patterns.
static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1>	CEPOperatorUtils.createTimeoutPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternFlatSelectFunction<IN,OUT1> selectFunction, TypeInformation<OUT1> outTypeInfo, OutputTag<OUT2> outputTag, PatternFlatTimeoutFunction<IN,OUT2> timeoutFunction) Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternFlatTimeoutFunction as a sideoutput.
static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1>	CEPOperatorUtils.createTimeoutPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternSelectFunction<IN,OUT1> selectFunction, TypeInformation<OUT1> outTypeInfo, OutputTag<OUT2> outputTag, PatternTimeoutFunction<IN,OUT2> timeoutFunction) Creates a data stream containing results of PatternSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternTimeoutFunction as a sideoutput.

Constructors in org.apache.flink.cep.operator with parameters of type EventComparator

Constructor and Description
AbstractKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy afterMatchSkipStrategy, F function)
FlatSelectCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternFlatSelectFunction<IN,OUT> function)
FlatSelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternFlatSelectFunction<IN,OUT1> flatSelectFunction, PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction, OutputTag<OUT2> outputTag)
SelectCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternSelectFunction<IN,OUT> function)
SelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternSelectFunction<IN,OUT1> flatSelectFunction, PatternTimeoutFunction<IN,OUT2> flatTimeoutFunction, OutputTag<OUT2> outputTag)