@PublicEvolving public final class Pipeline extends Object implements Estimator<Pipeline,PipelineModel>
Modifier and Type | Method and Description |
---|---|
PipelineModel |
fit(org.apache.flink.table.api.Table... inputs)
Trains the pipeline to fit on the given tables.
|
Map<Param<?>,Object> |
getParamMap()
Returns a map which should contain value for every parameter that meets one of the following
conditions.
|
static Pipeline |
load(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String path) |
void |
save(String path)
Saves this stage to the given path.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get, getParam, set
public PipelineModel fit(org.apache.flink.table.api.Table... inputs)
This method goes through all stages of this pipeline in order and does the following on each stage until the last Estimator (inclusive).
Estimator.fit(Table...)
with the input
tables to generate a Model. And if there is Estimator after this stage, transform the
input tables using the generated Model to get result tables, then pass the result
tables to the next stage as inputs.
After all the Estimators are trained to fit their input tables, a new PipelineModel will be created with the same stages in this pipeline, except that all the Estimators in the PipelineModel are replaced with the models generated in the above process.
fit
in interface Estimator<Pipeline,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<Pipeline>
public void save(String path) throws IOException
Stage
save
in interface Stage<Pipeline>
IOException
public static Pipeline load(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String path) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.