public class MapperAdapter extends Object implements MapFunction<Row,Row>
Mapper
to a MapFunction
so that the mapper can run in
Flink.Constructor and Description |
---|
MapperAdapter(Mapper mapper)
Construct a MapperAdapter with the given mapper.
|
public Row map(Row row) throws Exception
MapFunction
map
in interface MapFunction<Row,Row>
row
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.