Package | Description |
---|---|
org.apache.flink.cep.nfa | |
org.apache.flink.cep.operator | |
org.apache.flink.cep.pattern |
Modifier and Type | Method and Description |
---|---|
static AfterMatchSkipStrategy |
AfterMatchSkipStrategy.noSkip()
Every possible match will be emitted.
|
static AfterMatchSkipStrategy |
AfterMatchSkipStrategy.skipPastLastEvent()
Discards every partial match that contains event of the match.
|
static AfterMatchSkipStrategy |
AfterMatchSkipStrategy.skipToFirst(String patternName)
Discards every partial match that contains event of the match preceding the first of *PatternName*.
|
static AfterMatchSkipStrategy |
AfterMatchSkipStrategy.skipToLast(String patternName)
Discards every partial match that contains event of the match preceding the last of *PatternName*.
|
Modifier and Type | Method and Description |
---|---|
Tuple2<Collection<Map<String,List<T>>>,Collection<Tuple2<Map<String,List<T>>,Long>>> |
NFA.process(T event,
long timestamp,
AfterMatchSkipStrategy afterMatchSkipStrategy)
Processes the next input event.
|
Modifier and Type | Field and Description |
---|---|
protected AfterMatchSkipStrategy |
AbstractKeyedCEPPatternOperator.afterMatchSkipStrategy |
Modifier and Type | Method and Description |
---|---|
AfterMatchSkipStrategy |
Pattern.getAfterMatchSkipStrategy() |
Modifier and Type | Method and Description |
---|---|
static <T,F extends T> |
Pattern.begin(Pattern<T,F> group,
AfterMatchSkipStrategy afterMatchSkipStrategy)
Starts a new pattern sequence.
|
static <X> Pattern<X,X> |
Pattern.begin(String name,
AfterMatchSkipStrategy afterMatchSkipStrategy)
Starts a new pattern sequence.
|
Constructor and Description |
---|
Pattern(String name,
Pattern<T,? extends T> previous,
Quantifier.ConsumingStrategy consumingStrategy,
AfterMatchSkipStrategy afterMatchSkipStrategy) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.