org.apache.flink.cep.operator

Class FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>

java.lang.Object

org.apache.flink.cep.operator.FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>

All Implemented Interfaces:

Serializable, Function

Enclosing class:

FlatSelectTimeoutCepOperator<IN,OUT1,OUT2,KEY>

@Internal
public static class FlatSelectTimeoutCepOperator.FlatSelectWrapper<IN,OUT1,OUT2>
extends Object
implements Function

Wrapper that enables storing PatternFlatSelectFunction and PatternFlatTimeoutFunction functions in one udf.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlatSelectWrapper(PatternFlatSelectFunction<IN,OUT1> flatSelectFunction, PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction)

Method Summary

Modifier and Type	Method and Description
PatternFlatSelectFunction<IN,OUT1>	getFlatSelectFunction()
PatternFlatTimeoutFunction<IN,OUT2>	getFlatTimeoutFunction()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatSelectWrapper

public FlatSelectWrapper(PatternFlatSelectFunction<IN,OUT1> flatSelectFunction,
                         PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction)

Method Detail

getFlatSelectFunction

@VisibleForTesting
public PatternFlatSelectFunction<IN,OUT1> getFlatSelectFunction()

getFlatTimeoutFunction

@VisibleForTesting
public PatternFlatTimeoutFunction<IN,OUT2> getFlatTimeoutFunction()