IN
- Type of the input eventsKEY
- Type of the keypublic class TimeoutKeyedCEPPatternOperator<IN,KEY> extends AbstractKeyedCEPPatternOperator<IN,KEY,Either<Tuple2<Map<String,List<IN>>,Long>,Map<String,List<IN>>>>
Map
. The events are indexed by the event names associated in the pattern specification. The
operator works on keyed input data.AbstractStreamOperator.CountingOutput, AbstractStreamOperator.LatencyGauge
chainingStrategy, config, latencyGauge, LOG, metrics, output
Constructor and Description |
---|
TimeoutKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
TypeSerializer<KEY> keySerializer,
NFACompiler.NFAFactory<IN> nfaFactory,
boolean migratingFromOldKeyedOperator) |
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,List<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.
|
getPQSize, hasNonEmptyNFA, hasNonEmptyPQ, initializeState, onEventTime, onProcessingTime, open, processElement, restoreState
close, dispose, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, notifyOfCompletedCheckpoint, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotLegacyOperatorState, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker, processWatermark
close, dispose, getChainingStrategy, getMetricGroup, initializeState, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotLegacyOperatorState, snapshotState
public TimeoutKeyedCEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, TypeSerializer<KEY> keySerializer, NFACompiler.NFAFactory<IN> nfaFactory, boolean migratingFromOldKeyedOperator)
protected void processEvent(NFA<IN> nfa, IN event, long timestamp)
AbstractKeyedCEPPatternOperator
protected void advanceTime(NFA<IN> nfa, long timestamp)
AbstractKeyedCEPPatternOperator
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.