IN
- Type of the input elementsOUT
- Type of the output elementpublic abstract class RichPatternFlatSelectFunction<IN,OUT> extends AbstractRichFunction implements PatternFlatSelectFunction<IN,OUT>
PatternFlatSelectFunction
. As a RichFunction
, it gives access
to the RuntimeContext
and provides setup and
teardown methods: RichFunction.open(org.apache.flink.configuration.Configuration)
and
RichFunction.close()
.Constructor and Description |
---|
RichPatternFlatSelectFunction() |
Modifier and Type | Method and 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.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract void flatSelect(Map<String,List<IN>> pattern, Collector<OUT> out) throws Exception
PatternFlatSelectFunction
flatSelect
in interface PatternFlatSelectFunction<IN,OUT>
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.