IN
- Type of the input elementsKEY
- Type of the key on which the input stream is keyedOUT
- Type of the output elementspublic class SelectCepOperator<IN,KEY,OUT> extends AbstractKeyedCEPPatternOperator<IN,KEY,OUT,PatternSelectFunction<IN,OUT>>
AbstractKeyedCEPPatternOperator
that applies given PatternSelectFunction
to fully matched event patterns.AbstractStreamOperator.CountingOutput<OUT>
afterMatchSkipStrategy, lateDataOutputTag
userFunction
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
Constructor and Description |
---|
SelectCepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy skipStrategy,
PatternSelectFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
Modifier and Type | Method and Description |
---|---|
protected void |
processMatchedSequences(Iterable<Map<String,List<IN>>> matchingSequences,
long timestamp) |
getPQSize, hasNonEmptyPQ, hasNonEmptySharedBuffer, initializeState, onEventTime, onProcessingTime, open, processElement, processTimedOutSequences
close, dispose, getUserFunction, getUserFunctionParameters, notifyCheckpointComplete, setOutputType, setup, snapshotState
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, numEventTimeTimers, numProcessingTimeTimers, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker, processWatermark
close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, prepareSnapshotPreBarrier, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState
notifyCheckpointComplete
getCurrentKey, setCurrentKey
public SelectCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternSelectFunction<IN,OUT> function, OutputTag<IN> lateDataOutputTag)
protected void processMatchedSequences(Iterable<Map<String,List<IN>>> matchingSequences, long timestamp) throws Exception
processMatchedSequences
in class AbstractKeyedCEPPatternOperator<IN,KEY,OUT,PatternSelectFunction<IN,OUT>>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.