public class CEPOperatorUtils extends Object
Constructor and Description |
---|
CEPOperatorUtils() |
Modifier and Type | Method and Description |
---|---|
static <K,T> SingleOutputStreamOperator<Map<String,List<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> SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<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> SingleOutputStreamOperator<Map<String,List<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> SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> createTimeoutPatternStream(DataStream<T> inputStream, Pattern<T,?> pattern)
K
- Type of the keyEither
instance.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.