Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.functions.adaptors |
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(OutputTag<L> timedOutPartialMatchesTag,
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> timedOutPartialMatchesTag,
PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
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 |
Constructor and Description |
---|
PatternTimeoutFlatSelectAdapter(PatternFlatSelectFunction<IN,OUT> flatSelectFunction,
PatternFlatTimeoutFunction<IN,T> flatTimeoutFunction,
OutputTag<T> timedOutPartialMatchesTag) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.