org.apache.flink.cep.operator

Class FlatSelectTimeoutCepOperator<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,FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>>

org.apache.flink.cep.operator.FlatSelectTimeoutCepOperator<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 FlatSelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>
extends AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>>

Version of AbstractKeyedCEPPatternOperator that applies given PatternFlatSelectFunction to fully matched event patterns and PatternFlatTimeoutFunction 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	FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2> Wrapper that enables storing PatternFlatSelectFunction and PatternFlatTimeoutFunction functions 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
FlatSelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer, boolean isProcessingTime, NFACompiler.NFAFactory<IN> nfaFactory, EventComparator<IN> comparator, AfterMatchSkipStrategy skipStrategy, PatternFlatSelectFunction<IN,OUT1> flatSelectFunction, PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction, OutputTag<OUT2> outputTag)

Method Summary

Modifier and Type	Method and Description
void	open() This method is called immediately before any elements are processed, it should contain the operator's initialization logic, e.g.
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, 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

FlatSelectTimeoutCepOperator

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

Method Detail

open

public void open()
          throws Exception

Description copied from class: AbstractStreamOperator

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

The default implementation does nothing.

Specified by:

open in interface StreamOperator<OUT1>

Overrides:

open in class AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>>

Throws:

Exception - An exception in this method causes the operator to fail.

processMatchedSequences

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

Specified by:

processMatchedSequences in class AbstractKeyedCEPPatternOperator<IN,KEY,OUT1,FlatSelectTimeoutCepOperator.FlatSelectWrapper<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,FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>>

Throws:

Exception