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

Packages that use PatternFlatSelectFunction

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

Uses of PatternFlatSelectFunction in org.apache.flink.cep

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

Modifier and Type	Method and Description
<L,R> SingleOutputStreamOperator<R>	PatternStream.flatSelect(OutputTag<L> timeoutOutputTag, PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction, PatternFlatSelectFunction<T,R> patternFlatSelectFunction) Applies a flat select function to the detected pattern sequence.
<L,R> SingleOutputStreamOperator<R>	PatternStream.flatSelect(OutputTag<L> timeoutOutputTag, PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction, TypeInformation<R> outTypeInfo, PatternFlatSelectFunction<T,R> patternFlatSelectFunction) Applies a flat select function to the detected pattern sequence.
<R> SingleOutputStreamOperator<R>	PatternStream.flatSelect(PatternFlatSelectFunction<T,R> patternFlatSelectFunction) Applies a flat select function to the detected pattern sequence.
<R> SingleOutputStreamOperator<R>	PatternStream.flatSelect(PatternFlatSelectFunction<T,R> patternFlatSelectFunction, TypeInformation<R> outTypeInfo) Applies a flat select function to the detected pattern sequence.
<L,R> SingleOutputStreamOperator<Either<L,R>>	PatternStream.flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction, PatternFlatSelectFunction<T,R> patternFlatSelectFunction) Deprecated. Use PatternStream.flatSelect(OutputTag, PatternFlatTimeoutFunction, PatternFlatSelectFunction) that returns timed out events as a side-output

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

Methods in org.apache.flink.cep.operator that return PatternFlatSelectFunction

Modifier and Type	Method and Description
PatternFlatSelectFunction<IN,OUT1>	FlatSelectTimeoutCepOperator.FlatSelectWrapper.getFlatSelectFunction()

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

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,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.

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

Constructor and Description
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)
FlatSelectWrapper(PatternFlatSelectFunction<IN,OUT1> flatSelectFunction, PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction)