public class TimeoutKeyedCEPPatternOperator<IN,KEY> extends AbstractKeyedCEPPatternOperator<IN,KEY,Either<Tuple2<Map<String,IN>,Long>,Map<String,IN>>>
AbstractStreamOperator.CountingOutput, AbstractStreamOperator.LatencyGauge
INITIAL_PRIORITY_QUEUE_CAPACITY
chainingStrategy, config, latencyGauge, 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, snapshotState, updateNFA, updatePriorityQueue
getInputSerializer
close, dispose, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorName, getOperatorStateBackend, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyOfCompletedCheckpoint, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotLegacyOperatorState, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker
close, dispose, getChainingStrategy, getMetricGroup, initializeState, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotLegacyOperatorState, snapshotState
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.