org.apache.flink.cep.operator

Class CEPOperatorUtils

java.lang.Object

org.apache.flink.cep.operator.CEPOperatorUtils

public class CEPOperatorUtils
extends Object

Utility methods for creating PatternStream.

Constructor Summary

Constructors

Constructor and Description
CEPOperatorUtils()

Method Summary

Modifier and Type	Method and Description
static <IN,OUT> SingleOutputStreamOperator<OUT>	createPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternFlatSelectFunction<IN,OUT> selectFunction, TypeInformation<OUT> outTypeInfo) Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns.
static <IN,OUT> SingleOutputStreamOperator<OUT>	createPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternSelectFunction<IN,OUT> selectFunction, TypeInformation<OUT> outTypeInfo) Creates a data stream containing results of PatternSelectFunction to fully matching event patterns.
static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1>	createTimeoutPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternFlatSelectFunction<IN,OUT1> selectFunction, TypeInformation<OUT1> outTypeInfo, OutputTag<OUT2> outputTag, PatternFlatTimeoutFunction<IN,OUT2> timeoutFunction) Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternFlatTimeoutFunction as a sideoutput.
static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1>	createTimeoutPatternStream(DataStream<IN> inputStream, Pattern<IN,?> pattern, EventComparator<IN> comparator, PatternSelectFunction<IN,OUT1> selectFunction, TypeInformation<OUT1> outTypeInfo, OutputTag<OUT2> outputTag, PatternTimeoutFunction<IN,OUT2> timeoutFunction) Creates a data stream containing results of PatternSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternTimeoutFunction as a sideoutput.

Methods inherited from class java.lang.Object

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

Constructor Detail

CEPOperatorUtils

public CEPOperatorUtils()

Method Detail

createPatternStream

public static <IN,OUT> SingleOutputStreamOperator<OUT> createPatternStream(DataStream<IN> inputStream,
                                                                           Pattern<IN,?> pattern,
                                                                           EventComparator<IN> comparator,
                                                                           PatternSelectFunction<IN,OUT> selectFunction,
                                                                           TypeInformation<OUT> outTypeInfo)

Creates a data stream containing results of PatternSelectFunction to fully matching event patterns.

Type Parameters:

IN - type of input events

OUT - type of output events

Parameters:

inputStream - stream of input events

pattern - pattern to be search for in the stream

selectFunction - function to be applied to matching event sequences

outTypeInfo - output TypeInformation of selectFunction

Returns:

Data stream containing fully matched event sequence with applied PatternSelectFunction

createPatternStream

public static <IN,OUT> SingleOutputStreamOperator<OUT> createPatternStream(DataStream<IN> inputStream,
                                                                           Pattern<IN,?> pattern,
                                                                           EventComparator<IN> comparator,
                                                                           PatternFlatSelectFunction<IN,OUT> selectFunction,
                                                                           TypeInformation<OUT> outTypeInfo)

Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns.

Type Parameters:

IN - type of input events

OUT - type of output events

Parameters:

inputStream - stream of input events

pattern - pattern to be search for in the stream

selectFunction - function to be applied to matching event sequences

outTypeInfo - output TypeInformation of selectFunction

Returns:

Data stream containing fully matched event sequence with applied PatternFlatSelectFunction

createTimeoutPatternStream

public static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1> createTimeoutPatternStream(DataStream<IN> inputStream,
                                                                                         Pattern<IN,?> pattern,
                                                                                         EventComparator<IN> comparator,
                                                                                         PatternFlatSelectFunction<IN,OUT1> selectFunction,
                                                                                         TypeInformation<OUT1> outTypeInfo,
                                                                                         OutputTag<OUT2> outputTag,
                                                                                         PatternFlatTimeoutFunction<IN,OUT2> timeoutFunction)

Creates a data stream containing results of PatternFlatSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternFlatTimeoutFunction as a sideoutput.

Type Parameters:

IN - type of input events

OUT1 - type of fully matched events

OUT2 - type of timed out events

Parameters:

inputStream - stream of input events

pattern - pattern to be search for in the stream

selectFunction - function to be applied to matching event sequences

outTypeInfo - output TypeInformation of selectFunction

outputTag - OutputTag for a side-output with timed out matches

timeoutFunction - function to be applied to timed out event sequences

Returns:

Data stream containing fully matched event sequence with applied PatternFlatSelectFunction that contains timed out patterns with applied PatternFlatTimeoutFunction as side-output

createTimeoutPatternStream

public static <IN,OUT1,OUT2> SingleOutputStreamOperator<OUT1> createTimeoutPatternStream(DataStream<IN> inputStream,
                                                                                         Pattern<IN,?> pattern,
                                                                                         EventComparator<IN> comparator,
                                                                                         PatternSelectFunction<IN,OUT1> selectFunction,
                                                                                         TypeInformation<OUT1> outTypeInfo,
                                                                                         OutputTag<OUT2> outputTag,
                                                                                         PatternTimeoutFunction<IN,OUT2> timeoutFunction)

Creates a data stream containing results of PatternSelectFunction to fully matching event patterns and also timed out partially matched with applied PatternTimeoutFunction as a sideoutput.

Type Parameters:

IN - type of input events

OUT1 - type of fully matched events

OUT2 - type of timed out events

Parameters:

inputStream - stream of input events

pattern - pattern to be search for in the stream

selectFunction - function to be applied to matching event sequences

outTypeInfo - output TypeInformation of selectFunction

outputTag - OutputTag for a side-output with timed out matches

timeoutFunction - function to be applied to timed out event sequences

Returns:

Data stream containing fully matched event sequence with applied PatternSelectFunction that contains timed out patterns with applied PatternTimeoutFunction as side-output