IN
- Type of the input elementsOUT
- Type of the output elementpublic abstract class RichPatternSelectFunction<IN,OUT> extends AbstractRichFunction implements PatternSelectFunction<IN,OUT>
PatternSelectFunction
. 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 |
---|
RichPatternSelectFunction() |
Modifier and Type | Method and Description |
---|---|
abstract OUT |
select(Map<String,List<IN>> pattern)
Generates a result from the given map of events.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract OUT select(Map<String,List<IN>> pattern) throws Exception
PatternSelectFunction
select
in interface PatternSelectFunction<IN,OUT>
pattern
- Map containing the found pattern. Events are identified by their namesException
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.