public class CEPOperatorUtils extends Object
Constructor and Description |
---|
CEPOperatorUtils() |
Modifier and Type | Method and Description |
---|---|
static <K,T> DataStream<Map<String,T>> |
createPatternStream(DataStream<T> inputStream,
Pattern<T,?> pattern)
Creates a data stream containing the fully matching event patterns of the NFA computation.
|
static <K,T> DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> |
createTimeoutPatternStream(DataStream<T> inputStream,
Pattern<T,?> pattern)
Creates a data stream containing fully matching event patterns or partially matching event
patterns which have timed out.
|
public static <K,T> DataStream<Map<String,T>> createPatternStream(DataStream<T> inputStream, Pattern<T,?> pattern)
K
- Type of the keyMap
. The
events are indexed by their associated names of the pattern.public static <K,T> DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> createTimeoutPatternStream(DataStream<T> inputStream, Pattern<T,?> pattern)
K
- Type of the keyEither
instance.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.