IN
- Type of the input elementspublic abstract class AbstractCEPPatternOperator<IN> extends AbstractStreamOperator<Map<String,IN>> implements OneInputStreamOperator<IN,Map<String,IN>>
NFA
to detect complex event
patterns. The detected event patterns are then outputted to the down stream operators.Modifier and Type | Field and Description |
---|---|
protected static int |
INITIAL_PRIORITY_QUEUE_CAPACITY |
chainingStrategy, LOG, output
Constructor and Description |
---|
AbstractCEPPatternOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<IN> |
getInputSerializer() |
protected abstract NFA<IN> |
getNFA() |
protected abstract PriorityQueue<StreamRecord<IN>> |
getPriorityQueue() |
void |
processElement(StreamRecord<IN> element)
Processes one element that arrived at this operator.
|
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.
|
close, disableInputCopy, dispose, getChainingStrategy, getContainingTask, getExecutionConfig, getOperatorConfig, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, isInputCopyingDisabled, notifyOfCompletedCheckpoint, open, registerTimer, restoreState, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processWatermark
close, dispose, getChainingStrategy, isInputCopyingDisabled, notifyOfCompletedCheckpoint, open, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
protected static final int INITIAL_PRIORITY_QUEUE_CAPACITY
public AbstractCEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime)
public TypeSerializer<IN> getInputSerializer()
protected abstract NFA<IN> getNFA() throws IOException
IOException
protected abstract PriorityQueue<StreamRecord<IN>> getPriorityQueue() throws IOException
IOException
public void processElement(StreamRecord<IN> element) throws Exception
OneInputStreamOperator
processElement
in interface OneInputStreamOperator<IN,Map<String,IN>>
Exception
protected void processEvent(NFA<IN> nfa, IN event, long timestamp)
nfa
- NFA to be used for the event detectionevent
- The current event to be processedtimestamp
- The timestamp of the eventCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.