org.apache.flink.cep.operator

Class SelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,F>

org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2>>

org.apache.flink.cep.operator.SelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>

Type Parameters:

IN - Type of the input elements

KEY - Type of the key on which the input stream is keyed

OUT1 - Type of the output elements

OUT2 - Type of the timed out output elements

All Implemented Interfaces:

Serializable, CheckpointListener, KeyContext, OneInputStreamOperator<IN,OUT1>, OutputTypeConfigurable<OUT1>, StreamOperator<OUT1>, Triggerable<KEY,VoidNamespace>, Disposable

public class SelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>
extends AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2>>

Version of AbstractKeyedCEPPatternOperator that applies given PatternSelectFunction to fully matched event patterns and PatternTimeoutFunction to timed out ones. The timed out elements are returned as a side-output.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2> Wrapper that enables storing PatternSelectFunction and PatternTimeoutFunction in one udf.

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

AbstractStreamOperator.CountingOutput

Field Summary

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

afterMatchSkipStrategy

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

userFunction

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

chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager

Constructor Summary

Constructors

Constructor and Description
SelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternSelectFunction<IN,OUT1> flatSelectFunction, PatternTimeoutFunction<IN,OUT2> flatTimeoutFunction, OutputTag<OUT2> outputTag)

Method Summary

Modifier and Type	Method and Description
protected void	processMatchedSequences(Iterable<Map<String,List<IN>>> matchingSequences, long timestamp)
protected void	processTimedOutSequences(Iterable<Tuple2<Map<String,List<IN>>,Long>> timedOutSequences, long timestamp)

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

getPQSize, hasNonEmptyNFA, hasNonEmptyPQ, initializeState, onEventTime, onProcessingTime, open, processElement

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

close, dispose, getUserFunction, getUserFunctionParameters, notifyCheckpointComplete, setOutputType, setup, snapshotState

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

getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState

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.OneInputStreamOperator

processLatencyMarker, processWatermark

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

close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState

Methods inherited from interface org.apache.flink.runtime.state.CheckpointListener

notifyCheckpointComplete

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

getCurrentKey, setCurrentKey

Constructor Detail

SelectTimeoutCepOperator

public SelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer,
                                boolean isProcessingTime,
                                NFACompiler.NFAFactory<IN> nfaFactory,
                                EventComparator<IN> comparator,
                                AfterMatchSkipStrategy skipStrategy,
                                PatternSelectFunction<IN,OUT1> flatSelectFunction,
                                PatternTimeoutFunction<IN,OUT2> flatTimeoutFunction,
                                OutputTag<OUT2> outputTag)

Method Detail

processMatchedSequences

protected void processMatchedSequences(Iterable<Map<String,List<IN>>> matchingSequences,
                                       long timestamp)
                                throws Exception

Specified by:

processMatchedSequences in class AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2>>

Throws:

Exception

processTimedOutSequences

protected void processTimedOutSequences(Iterable<Tuple2<Map<String,List<IN>>,Long>> timedOutSequences,
                                        long timestamp)
                                 throws Exception

Overrides:

processTimedOutSequences in class AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,SelectTimeoutCepOperator.SelectWrapper<IN,OUT1,OUT2>>

Throws:

Exception