public class ModelMapperAdapter extends RichMapFunction<Row,Row>
ModelMapper
to a Flink RichMapFunction
so the model can be
loaded in a Flink job.
This adapter class hold the target ModelMapper
and it's ModelSource
. Upon open(),
it will load model rows from ModelSource
into ModelMapper
.
Constructor and Description |
---|
ModelMapperAdapter(ModelMapper mapper,
ModelSource modelSource)
Construct a ModelMapperAdapter with the given ModelMapper and ModelSource.
|
Modifier and Type | Method and Description |
---|---|
Row |
map(Row row)
The mapping method.
|
void |
open(Configuration parameters)
Initialization method for the function.
|
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public ModelMapperAdapter(ModelMapper mapper, ModelSource modelSource)
mapper
- The ModelMapper
to adapt.modelSource
- The ModelSource
to load the model from.public void open(Configuration parameters) throws Exception
RichFunction
The configuration object passed to the function can be used for configuration and initialization. The configuration contains all parameters that were configured on the function in the program composition.
public class MyFilter extends RichFilterFunction<String> {
private String searchString;
public void open(Configuration parameters) {
this.searchString = parameters.getString("foo");
}
public boolean filter(String value) {
return value.equals(searchString);
}
}
By default, this method does nothing.
open
in interface RichFunction
open
in class AbstractRichFunction
parameters
- The configuration containing the parameters attached to the contract.Exception
- Implementations may forward exceptions, which are caught by the runtime. When the
runtime catches an exception, it aborts the task and lets the fail-over logic
decide whether to retry the task execution.Configuration
public Row map(Row row) throws Exception
MapFunction
map
in interface MapFunction<Row,Row>
map
in class RichMapFunction<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–2020 The Apache Software Foundation. All rights reserved.