Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.scala |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<R> DataStream<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction,
TypeInformation<R> outTypeInfo)
Applies a select function to the detected pattern sequence.
|
<L,R> DataStream<Either<L,R>> |
PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
PatternStream.select(PatternSelectFunction<T,R> patternSelectFunction,
TypeInformation<R> evidence$1)
Applies a select function to the detected pattern sequence.
|
<L,R> DataStream<scala.util.Either<L,R>> |
PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction,
TypeInformation<L> evidence$2,
TypeInformation<R> evidence$3)
Applies a select function to the detected pattern sequence.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.