public class TimeoutKeyedCEPPatternOperator<IN,KEY> extends AbstractKeyedCEPPatternOperator<IN,KEY,Either<Tuple2<Map<String,IN>,Long>,Map<String,IN>>>
AbstractStreamOperator.CountingOutput
INITIAL_PRIORITY_QUEUE_CAPACITY
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
TimeoutKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
KeySelector<IN,KEY> keySelector,
TypeSerializer<KEY> keySerializer,
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, processElement, processWatermark, restoreState, snapshotOperatorState, updateNFA, updatePriorityQueue
getInputSerializer
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 TimeoutKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, KeySelector<IN,KEY> keySelector, TypeSerializer<KEY> keySerializer, 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.