@PublicEvolving public final class PipelineModel extends Object implements Model<PipelineModel>
Constructor and Description |
---|
PipelineModel(List<Stage<?>> stages) |
Modifier and Type | Method and Description |
---|---|
Map<Param<?>,Object> |
getParamMap()
Returns a map which should contain value for every parameter that meets one of the following
conditions.
|
static PipelineModel |
load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv,
String path) |
static PipelineModelServable |
loadServable(String path) |
void |
save(String path)
Saves the metadata and bounded data of this stage to the given path.
|
boolean |
supportServable()
Whether all stages in the pipeline have corresponding
TransformerServable so that the
PipelineModel can be turned into a TransformerServable and used in an online inference
program. |
org.apache.flink.table.api.Table[] |
transform(org.apache.flink.table.api.Table... inputs)
Applies all stages in this PipelineModel on the input tables in order.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getModelData, setModelData
get, getParam, set
public org.apache.flink.table.api.Table[] transform(org.apache.flink.table.api.Table... inputs)
transform
in interface AlgoOperator<PipelineModel>
inputs
- a list of tablespublic Map<Param<?>,Object> getParamMap()
WithParams
1) set(...) has been called to set value for this parameter.
2) The parameter is a public final field of this WithParams instance. This includes fields inherited from its interfaces and super-classes.
The subclass which implements this interface could meet this requirement by returning a
member field of the given map type, after having initialized this member field using the
ParamUtils.initializeMapWithDefaultValues(Map, WithParams)
method.
getParamMap
in interface WithParams<PipelineModel>
public void save(String path) throws IOException
Stage
save
in interface Stage<PipelineModel>
IOException
public static PipelineModel load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv, String path) throws IOException
IOException
public static PipelineModelServable loadServable(String path) throws IOException
IOException
public boolean supportServable()
TransformerServable
so that the
PipelineModel can be turned into a TransformerServable and used in an online inference
program.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.