org.apache.flink.cep.operator

Class CEPPatternOperator<IN>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator<Map<String,IN>>

org.apache.flink.cep.operator.AbstractCEPPatternOperator<IN>

org.apache.flink.cep.operator.CEPPatternOperator<IN>

Type Parameters:

IN - Type of the input elements

All Implemented Interfaces:

Serializable, OneInputStreamOperator<IN,Map<String,IN>>, StreamOperator<Map<String,IN>>

public class CEPPatternOperator<IN>
extends AbstractCEPPatternOperator<IN>

CEP pattern operator implementation which is used for non keyed streams. Consequently, the operator state only includes a single NFA and a priority queue to order out of order elements in case of event time processing.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cep.operator.AbstractCEPPatternOperator

INITIAL_PRIORITY_QUEUE_CAPACITY

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

chainingStrategy, LOG, output

Constructor Summary

Constructors

Constructor and Description
CEPPatternOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory)

Method Summary

Modifier and Type	Method and Description
protected NFA<IN>	getNFA()
protected PriorityQueue<StreamRecord<IN>>	getPriorityQueue()
void	open() This method is called immediately before any elements are processed, it should contain the operator's initialization logic.
void	processWatermark(Watermark mark) Processes a Watermark.
void	restoreState(StreamTaskState state, long recoveryTimestamp) Restores the operator state, if this operator's execution is recovering from a checkpoint.
StreamTaskState	snapshotOperatorState(long checkpointId, long timestamp) Called to draw a state snapshot from the operator.

Methods inherited from class org.apache.flink.cep.operator.AbstractCEPPatternOperator

getInputSerializer, processElement, processEvent

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

close, disableInputCopy, dispose, getChainingStrategy, getContainingTask, getExecutionConfig, getOperatorConfig, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, isInputCopyingDisabled, notifyOfCompletedCheckpoint, registerTimer, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2, setup

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

close, dispose, getChainingStrategy, isInputCopyingDisabled, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup

Constructor Detail

CEPPatternOperator

public CEPPatternOperator(TypeSerializer<IN> inputSerializer,
                          boolean isProcessingTime,
                          NFACompiler.NFAFactory<IN> nfaFactory)

Method Detail

open

public void open()

Description copied from class: AbstractStreamOperator

This method is called immediately before any elements are processed, it should contain the operator's initialization logic.

The default implementation does nothing.

Specified by:

open in interface StreamOperator<Map<String,IN>>

Overrides:

open in class AbstractStreamOperator<Map<String,IN>>

getNFA

protected NFA<IN> getNFA()
                  throws IOException

Specified by:

getNFA in class AbstractCEPPatternOperator<IN>

Throws:

IOException

getPriorityQueue

protected PriorityQueue<StreamRecord<IN>> getPriorityQueue()
                                                    throws IOException

Specified by:

getPriorityQueue in class AbstractCEPPatternOperator<IN>

Throws:

IOException

processWatermark

public void processWatermark(Watermark mark)
                      throws Exception

Description copied from interface: OneInputStreamOperator

Processes a Watermark. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

Watermark

snapshotOperatorState

public StreamTaskState snapshotOperatorState(long checkpointId,
                                             long timestamp)
                                      throws Exception

Description copied from interface: StreamOperator

Called to draw a state snapshot from the operator. This method snapshots the operator state (if the operator is stateful) and the key/value state (if it is being used and has been initialized).

Specified by:

snapshotOperatorState in interface StreamOperator<Map<String,IN>>

Overrides:

snapshotOperatorState in class AbstractStreamOperator<Map<String,IN>>

Parameters:

checkpointId - The ID of the checkpoint.

timestamp - The timestamp of the checkpoint.

Returns:

The StreamTaskState object, possibly containing the snapshots for the operator and key/value state.

Throws:

Exception - Forwards exceptions that occur while drawing snapshots from the operator and the key/value state.

restoreState

public void restoreState(StreamTaskState state,
                         long recoveryTimestamp)
                  throws Exception

Description copied from interface: StreamOperator

Restores the operator state, if this operator's execution is recovering from a checkpoint. This method restores the operator state (if the operator is stateful) and the key/value state (if it had been used and was initialized when the snapshot occurred).

This method is called after StreamOperator.setup(StreamTask, StreamConfig, Output) and before StreamOperator.open().

Specified by:

restoreState in interface StreamOperator<Map<String,IN>>

Overrides:

restoreState in class AbstractStreamOperator<Map<String,IN>>

Parameters:

state - The state of operator that was snapshotted as part of checkpoint from which the execution is restored.

recoveryTimestamp - Global recovery timestamp

Throws:

Exception - Exceptions during state restore should be forwarded, so that the system can properly react to failed state restore and fail the execution attempt.