Interface PatternFlatSelectFunction<IN,​OUT>

  • Type Parameters:
    IN -
    OUT -
    All Superinterfaces:
    Function, Serializable
    All Known Implementing Classes:
    RichPatternFlatSelectFunction

    public interface PatternFlatSelectFunction<IN,​OUT>
    extends Function, Serializable
    Base interface for a pattern select function which can produce multiple resulting elements. A pattern flat select function is called with a map of detected events which are identified by their names. The names are defined by the Pattern specifying the sought-after pattern. Additionally, a collector is provided as a parameter. The collector is used to emit an arbitrary number of resulting elements.
    
     PatternStream<IN> pattern = ...
    
     DataStream<OUT> result = pattern.flatSelect(new MyPatternFlatSelectFunction());
     
    • Method Detail

      • flatSelect

        void flatSelect​(Map<String,​List<IN>> pattern,
                        Collector<OUT> out)
                 throws Exception
        Generates zero or more resulting elements given a map of detected pattern events. The events are identified by their specified names.
        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.