Package | Description |
---|---|
org.apache.flink.cep |
Modifier and Type | Method and Description |
---|---|
PatternStream<T> |
PatternStream.inEventTime()
Sets the time characteristic to event time.
|
PatternStream<T> |
PatternStream.inProcessingTime()
Sets the time characteristic to processing time.
|
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern)
Creates a
PatternStream from an input data stream and a pattern. |
static <T> PatternStream<T> |
CEP.pattern(DataStream<T> input,
Pattern<T,?> pattern,
EventComparator<T> comparator)
Creates a
PatternStream from an input data stream and a pattern. |
PatternStream<T> |
PatternStream.sideOutputLateData(OutputTag<T> lateDataOutputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.