Package org.apache.flink.cep

Class RichPatternFlatSelectFunction<IN,OUT>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.cep.RichPatternFlatSelectFunction<IN,OUT>

Type Parameters:

IN - Type of the input elements

OUT - Type of the output element

All Implemented Interfaces:

Serializable, Function, RichFunction, PatternFlatSelectFunction<IN,OUT>

public abstract class RichPatternFlatSelectFunction<IN,OUT>
extends AbstractRichFunction
implements PatternFlatSelectFunction<IN,OUT>

Rich variant of the PatternFlatSelectFunction. As a RichFunction, it gives access to the RuntimeContext and provides setup and teardown methods: RichFunction.open(OpenContext) and RichFunction.close().

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RichPatternFlatSelectFunction()

Method Summary

Modifier and Type	Method	Description
abstract void	flatSelect(Map<String,List<IN>> pattern, Collector<OUT> out)	Generates zero or more resulting elements given a map of detected pattern events.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

RichPatternFlatSelectFunction

public RichPatternFlatSelectFunction()

Method Detail

flatSelect

public abstract void flatSelect(Map<String,List<IN>> pattern,
                                Collector<OUT> out)
                         throws Exception

Description copied from interface: PatternFlatSelectFunction

Generates zero or more resulting elements given a map of detected pattern events. The events are identified by their specified names.

Specified by:

flatSelect in interface PatternFlatSelectFunction<IN,OUT>

Parameters:

pattern - Map containing the found pattern. Events are identified by their names.

out - Collector used to output the generated elements

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.