public class PatternStream<T> extends Object
NFA
. In order to process the detected sequences, the user has to
specify a PatternSelectFunction
or a PatternFlatSelectFunction
.
Constructor and Description |
---|
PatternStream(PatternStream<T> jPatternStream) |
Modifier and Type | Method and Description |
---|---|
static <T> PatternStream<T> |
apply(PatternStream<T> jPatternStream) |
<R> DataStream<R> |
flatSelect(scala.Function2<scala.collection.mutable.Map<String,T>,Collector<R>,scala.runtime.BoxedUnit> patternFlatSelectFun,
TypeInformation<R> evidence$10)
Applies a flat select function to the detected pattern sequence.
|
<L,R> DataStream<scala.util.Either<L,R>> |
flatSelect(scala.Function3<scala.collection.mutable.Map<String,T>,Object,Collector<L>,scala.runtime.BoxedUnit> patternFlatTimeoutFunction,
scala.Function2<scala.collection.mutable.Map<String,T>,Collector<R>,scala.runtime.BoxedUnit> patternFlatSelectFunction,
TypeInformation<L> evidence$11,
TypeInformation<R> evidence$12)
Applies a flat select function to the detected pattern sequence.
|
<R> DataStream<R> |
flatSelect(PatternFlatSelectFunction<T,R> patternFlatSelectFunction,
TypeInformation<R> evidence$4)
Applies a flat select function to the detected pattern sequence.
|
<L,R> DataStream<scala.util.Either<L,R>> |
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.
|
DataStream<T> |
getInputStream() |
Pattern<T,T> |
getPattern() |
<R> DataStream<R> |
select(scala.Function1<scala.collection.mutable.Map<String,T>,R> patternSelectFun,
TypeInformation<R> evidence$7)
Applies a select function to the detected pattern sequence.
|
<L,R> DataStream<scala.util.Either<L,R>> |
select(scala.Function2<scala.collection.mutable.Map<String,T>,Object,L> patternTimeoutFunction,
scala.Function1<scala.collection.mutable.Map<String,T>,R> patternSelectFunction,
TypeInformation<L> evidence$8,
TypeInformation<R> evidence$9)
Applies a select function to the detected pattern sequence.
|
<R> DataStream<R> |
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>> |
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.
|
PatternStream<T> |
wrappedPatternStream() |
public PatternStream(PatternStream<T> jPatternStream)
public static <T> PatternStream<T> apply(PatternStream<T> jPatternStream)
jPatternStream
- Underlying pattern stream from Java APIpublic PatternStream<T> wrappedPatternStream()
public DataStream<T> getInputStream()
public <R> DataStream<R> select(PatternSelectFunction<T,R> patternSelectFunction, TypeInformation<R> evidence$1)
PatternSelectFunction
is called. The pattern select function can produce
exactly one resulting element.
patternSelectFunction
- The pattern select function which is called for each detected
pattern sequence.DataStream
which contains the resulting elements from the pattern select function.public <L,R> DataStream<scala.util.Either<L,R>> select(PatternTimeoutFunction<T,L> patternTimeoutFunction, PatternSelectFunction<T,R> patternSelectFunction, TypeInformation<L> evidence$2, TypeInformation<R> evidence$3)
PatternSelectFunction
is called. The pattern select function can produce
exactly one resulting element.
Additionally a timeout function is applied to partial event patterns which have timed out. For
each partial pattern sequence the provided PatternTimeoutFunction
is called. The pattern
timeout function has to produce exactly one resulting timeout event.
The resulting event and the resulting timeout event are wrapped in an Either
instance.
patternTimeoutFunction
- The pattern timeout function which is called for each partial
pattern sequence which has timed out.patternSelectFunction
- The pattern select function which is called for each detected
pattern sequence.public <R> DataStream<R> flatSelect(PatternFlatSelectFunction<T,R> patternFlatSelectFunction, TypeInformation<R> evidence$4)
PatternFlatSelectFunction
is called. The pattern flat select function can
produce an arbitrary number of resulting elements.
patternFlatSelectFunction
- The pattern flat select function which is called for each
detected pattern sequence.DataStream
which contains the resulting elements from the pattern flat select
function.public <L,R> DataStream<scala.util.Either<L,R>> flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction, PatternFlatSelectFunction<T,R> patternFlatSelectFunction, TypeInformation<L> evidence$5, TypeInformation<R> evidence$6)
PatternFlatSelectFunction
is called. The pattern flat select function can
produce an arbitrary number of resulting elements.
Additionally a timeout function is applied to partial event patterns which have timed out. For
each partial pattern sequence the provided PatternFlatTimeoutFunction
is called. The
pattern timeout function can produce an arbitrary number of resulting timeout events.
The resulting event and the resulting timeout event are wrapped in an Either
instance.
patternFlatTimeoutFunction
- The pattern flat timeout function which is called for each
partially matched pattern sequence which has timed out.patternFlatSelectFunction
- The pattern flat select function which is called for each
detected pattern sequence.Either
type.public <R> DataStream<R> select(scala.Function1<scala.collection.mutable.Map<String,T>,R> patternSelectFun, TypeInformation<R> evidence$7)
PatternSelectFunction
is called. The pattern select function can produce exactly
one resulting element.
patternSelectFun
- The pattern select function which is called for each detected
pattern sequence.DataStream
which contains the resulting elements from the pattern select function.public <L,R> DataStream<scala.util.Either<L,R>> select(scala.Function2<scala.collection.mutable.Map<String,T>,Object,L> patternTimeoutFunction, scala.Function1<scala.collection.mutable.Map<String,T>,R> patternSelectFunction, TypeInformation<L> evidence$8, TypeInformation<R> evidence$9)
PatternSelectFunction
is called. The pattern select function can produce
exactly one resulting element.
Additionally a timeout function is applied to partial event patterns which have timed out. For
each partial pattern sequence the provided PatternTimeoutFunction
is called. The pattern
timeout function has to produce exactly one resulting element.
The resulting event and the resulting timeout event are wrapped in an Either
instance.
patternTimeoutFunction
- The pattern timeout function which is called for each partial
pattern sequence which has timed out.patternSelectFunction
- The pattern select function which is called for each detected
pattern sequence.public <R> DataStream<R> flatSelect(scala.Function2<scala.collection.mutable.Map<String,T>,Collector<R>,scala.runtime.BoxedUnit> patternFlatSelectFun, TypeInformation<R> evidence$10)
PatternFlatSelectFunction
is called. The pattern flat select function
can produce an arbitrary number of resulting elements.
patternFlatSelectFun
- The pattern flat select function which is called for each
detected pattern sequence.DataStream
which contains the resulting elements from the pattern flat select
function.public <L,R> DataStream<scala.util.Either<L,R>> flatSelect(scala.Function3<scala.collection.mutable.Map<String,T>,Object,Collector<L>,scala.runtime.BoxedUnit> patternFlatTimeoutFunction, scala.Function2<scala.collection.mutable.Map<String,T>,Collector<R>,scala.runtime.BoxedUnit> patternFlatSelectFunction, TypeInformation<L> evidence$11, TypeInformation<R> evidence$12)
PatternFlatSelectFunction
is called. The pattern flat select function can
produce an arbitrary number of resulting elements.
Additionally a timeout function is applied to partial event patterns which have timed out. For
each partial pattern sequence the provided PatternFlatTimeoutFunction
is called. The
pattern timeout function can produce an arbitrary number of resulting timeout events.
The resulting event and the resulting timeout event are wrapped in an Either
instance.
patternFlatTimeoutFunction
- The pattern flat timeout function which is called for each
partially matched pattern sequence which has timed out.patternFlatSelectFunction
- The pattern flat select function which is called for each
detected pattern sequence.Either
type.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.