Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.functions.adaptors |
Modifier and Type | Class and Description |
---|---|
class |
RichPatternSelectFunction<IN,OUT>
Rich variant of the
PatternSelectFunction . |
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.select(OutputTag<L> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.select(OutputTag<L> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<R> SingleOutputStreamOperator<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction,
TypeInformation<R> outTypeInfo)
Applies a select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<Either<L,R>> |
PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction)
Deprecated.
Use
PatternStream.select(OutputTag, PatternTimeoutFunction, PatternSelectFunction)
that returns timed out events as a side-output |
Constructor and Description |
---|
PatternSelectAdapter(PatternSelectFunction<IN,OUT> selectFunction) |
PatternTimeoutSelectAdapter(PatternSelectFunction<IN,OUT> selectFunction,
PatternTimeoutFunction<IN,T> timeoutFunction,
OutputTag<T> timedOutPartialMatchesTag) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.