AbstractKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy afterMatchSkipStrategy,
F function,
OutputTag<IN> lateDataOutputTag) |
FlatSelectCepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy skipStrategy,
PatternFlatSelectFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
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,
OutputTag<IN> lateDataOutputTag) |
SelectCepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy skipStrategy,
PatternSelectFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
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,
OutputTag<IN> lateDataOutputTag) |