public class OnlineLogisticRegression extends Object implements Estimator<OnlineLogisticRegression,OnlineLogisticRegressionModel>, OnlineLogisticRegressionParams<OnlineLogisticRegression>
See H. Brendan McMahan et al., Ad click prediction: a view from the trenches.
ALPHA, BETA
LABEL_COL
WEIGHT_COL
BATCH_STRATEGY, COUNT_STRATEGY
GLOBAL_BATCH_SIZE
ELASTIC_NET
MODEL_VERSION_COL
FEATURES_COL
PREDICTION_COL
RAW_PREDICTION_COL
Constructor and Description |
---|
OnlineLogisticRegression() |
Modifier and Type | Method and Description |
---|---|
OnlineLogisticRegressionModel |
fit(org.apache.flink.table.api.Table... inputs)
Trains on the given inputs and produces a Model.
|
Map<Param<?>,Object> |
getParamMap()
Returns a map which should contain value for every parameter that meets one of the following
conditions.
|
static OnlineLogisticRegression |
load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv,
String path) |
void |
save(String path)
Saves the metadata and bounded data of this stage to the given path.
|
OnlineLogisticRegression |
setInitialModelData(org.apache.flink.table.api.Table initModelDataTable)
Sets the initial model data of the online training process with the provided model data
table.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAlpha, getBeta, setAlpha, setBeta
getLabelCol, setLabelCol
getWeightCol, setWeightCol
getBatchStrategy
getGlobalBatchSize, setGlobalBatchSize
getElasticNet, setElasticNet
getModelVersionCol, setModelVersionCol
getFeaturesCol, setFeaturesCol
getPredictionCol, setPredictionCol
getRawPredictionCol, setRawPredictionCol
get, getParam, set
public OnlineLogisticRegressionModel fit(org.apache.flink.table.api.Table... inputs)
Estimator
fit
in interface Estimator<OnlineLogisticRegression,OnlineLogisticRegressionModel>
inputs
- a list of tablespublic void save(String path) throws IOException
Stage
save
in interface Stage<OnlineLogisticRegression>
IOException
public static OnlineLogisticRegression load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv, String path) throws IOException
IOException
public 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<OnlineLogisticRegression>
public OnlineLogisticRegression setInitialModelData(org.apache.flink.table.api.Table initModelDataTable)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.