Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.scala |
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<Either<L,R>> |
PatternStream.flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
Applies a flat select function to the detected pattern sequence.
|
Modifier and Type | Method and Description |
---|---|
<L,R> DataStream<scala.util.Either<L,R>> |
PatternStream.flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction,
TypeInformation<L> evidence$5,
TypeInformation<R> evidence$6)
Applies a flat select function to the detected pattern sequence.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.