IN
- Type of the input eventspublic class CEPPatternOperator<IN> extends AbstractCEPPatternOperator<IN,Map<String,IN>>
Map
. The
events are indexed by the event names associated in the pattern specification.AbstractStreamOperator.CountingOutput
INITIAL_PRIORITY_QUEUE_CAPACITY
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
CEPPatternOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
advanceTime(NFA<IN> nfa,
long timestamp)
Advances the time for the given NFA to the given timestamp.
|
protected void |
processEvent(NFA<IN> nfa,
IN event,
long timestamp)
Process the given event by giving it to the NFA and outputting the produced set of matched
event sequences.
|
getNFA, getPriorityQueue, open, processWatermark, restoreState, snapshotOperatorState, updateNFA, updatePriorityQueue
getInputSerializer, processElement
close, dispose, getChainingStrategy, getContainingTask, getCurrentProcessingTime, getExecutionConfig, getMetricGroup, getOperatorConfig, getOperatorName, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, notifyOfCompletedCheckpoint, registerTimer, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2, setup
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, dispose, getChainingStrategy, getMetricGroup, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup
public CEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory)
protected void processEvent(NFA<IN> nfa, IN event, long timestamp)
AbstractCEPBasePatternOperator
processEvent
in class AbstractCEPBasePatternOperator<IN,Map<String,IN>>
nfa
- NFA to be used for the event detectionevent
- The current event to be processedtimestamp
- The timestamp of the eventprotected void advanceTime(NFA<IN> nfa, long timestamp)
AbstractCEPBasePatternOperator
advanceTime
in class AbstractCEPBasePatternOperator<IN,Map<String,IN>>
nfa
- to advance the time fortimestamp
- to advance the time toCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.