IN
- Type of the input elements.OUT
- Type of the returned elements.@Public public abstract class RichMapFunction<IN,OUT> extends AbstractRichFunction implements MapFunction<IN,OUT>
MapFunction
. 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 |
---|
RichMapFunction() |
Modifier and Type | Method and Description |
---|---|
abstract OUT |
map(IN value)
The mapping method.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract OUT map(IN value) throws Exception
MapFunction
map
in interface MapFunction<IN,OUT>
value
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.