IN
- OUT
- public interface PatternFlatSelectFunction<IN,OUT> extends Function, Serializable
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());
Modifier and Type | Method and Description |
---|---|
void |
flatSelect(Map<String,List<IN>> pattern,
Collector<OUT> out)
Generates zero or more resulting elements given a map of detected pattern events.
|
void flatSelect(Map<String,List<IN>> pattern, Collector<OUT> out) throws Exception
pattern
- Map containing the found pattern. Events are identified by their names.out
- Collector used to output the generated elementsException
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.