IN
- Type of the input eventspublic class TimeoutCEPPatternOperator<IN> extends AbstractCEPPatternOperator<IN,Either<Tuple2<Map<String,IN>,Long>,Map<String,IN>>>
Either
. The matched events are stored in a
Map
and are indexed by the event names associated in the pattern specification.
The fully matched event patterns are returned as a Either.Right
instance and the
partially matched event patterns are returned as a Either.Left
instance.AbstractStreamOperator.CountingOutput
INITIAL_PRIORITY_QUEUE_CAPACITY
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
TimeoutCEPPatternOperator(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 |
emitMatchedSequences(Iterable<Map<String,IN>> matchedSequences,
long 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 TimeoutCEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory)
protected void processEvent(NFA<IN> nfa, IN event, long timestamp)
AbstractCEPBasePatternOperator
protected void advanceTime(NFA<IN> nfa, long timestamp)
AbstractCEPBasePatternOperator
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.