<L,R> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<org.apache.flink.types.Either<L,R>> |
PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction) |
Deprecated.
|
<L,R> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> |
PatternStream.select(org.apache.flink.util.OutputTag<L> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
org.apache.flink.api.common.typeinfo.TypeInformation<R> outTypeInfo,
PatternSelectFunction<T,R> patternSelectFunction) |
Applies a select function to the detected pattern sequence.
|
<L,R> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> |
PatternStream.select(org.apache.flink.util.OutputTag<L> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction) |
Applies a select function to the detected pattern sequence.
|