Package | Description |
---|---|
org.apache.flink.cep.nfa |
Modifier and Type | Method and Description |
---|---|
Collection<Map<String,List<T>>> |
NFA.process(SharedBufferAccessor<T> sharedBufferAccessor,
NFAState nfaState,
T event,
long timestamp,
AfterMatchSkipStrategy afterMatchSkipStrategy,
TimerService timerService)
Processes the next input event.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.