E
- A subclass of the EstimatorBase
, used by WithParams
M
- class type of the ModelBase
this Estimator produces.public abstract class EstimatorBase<E extends EstimatorBase<E,M>,M extends ModelBase<M>> extends PipelineStageBase<E> implements Estimator<E,M>
params
ML_ENVIRONMENT_ID
Constructor and Description |
---|
EstimatorBase() |
EstimatorBase(Params params) |
Modifier and Type | Method and Description |
---|---|
protected abstract M |
fit(BatchOperator input)
Train and produce a
ModelBase which fits the records from the given BatchOperator . |
protected M |
fit(StreamOperator input)
Online learning and produce
ModelBase series which fit the streaming records from the
given StreamOperator . |
M |
fit(Table input)
|
M |
fit(TableEnvironment tEnv,
Table input)
|
default void |
loadJson(String json) |
default String |
toJson() |
clone, getParams, tableEnvOf
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get, getParams, set
getMLEnvironmentId, setMLEnvironmentId
public EstimatorBase()
public EstimatorBase(Params params)
public M fit(TableEnvironment tEnv, Table input)
Estimator
public M fit(Table input)
input
- the table with records to train the Model.protected abstract M fit(BatchOperator input)
ModelBase
which fits the records from the given BatchOperator
.input
- the table with records to train the Model.protected M fit(StreamOperator input)
ModelBase
series which fit the streaming records from the
given StreamOperator
.input
- the StreamOperator with streaming records to online train the Model series.public String toJson()
public void loadJson(String json)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.