This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
from 80fd4dfb [FLINK-30933] Fix missing max watermark when executing join
in iteration body
add 6a92e363 [FLINK-31422] Move common params from flink-ml-lib to
flink-ml-servable-lib
new adc18989 [FLINK-31422] Add Servable for Logistic Regression Model
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-ml-benchmark/pom.xml | 7 ++
.../java/org/apache/flink/ml/util/TestUtils.java | 19 ++++
flink-ml-lib/pom.xml | 14 +++
.../logisticregression/LogisticRegression.java | 2 +-
.../LogisticRegressionModel.java | 51 ++++-----
...a.java => LogisticRegressionModelDataUtil.java} | 60 ++++++-----
.../OnlineLogisticRegression.java | 8 +-
.../OnlineLogisticRegressionModel.java | 29 ++++--
.../ml/classification/LogisticRegressionTest.java | 84 ++++++++++++++-
.../OnlineLogisticRegressionTest.java | 6 +-
{flink-ml-tests => flink-ml-servable-lib}/pom.xml | 48 +++++----
.../LogisticRegressionModelData.java | 76 ++++++++++++++
.../LogisticRegressionModelParams.java | 2 +-
.../LogisticRegressionModelServable.java | 116 +++++++++++++++++++++
.../flink/ml/common/param/HasBatchStrategy.java | 0
.../flink/ml/common/param/HasCategoricalCols.java | 0
.../flink/ml/common/param/HasDecayFactor.java | 0
.../flink/ml/common/param/HasDistanceMeasure.java | 0
.../flink/ml/common/param/HasElasticNet.java | 0
.../flink/ml/common/param/HasFeaturesCol.java | 3 +-
.../apache/flink/ml/common/param/HasFlatten.java | 0
.../flink/ml/common/param/HasGlobalBatchSize.java | 0
.../flink/ml/common/param/HasHandleInvalid.java | 0
.../apache/flink/ml/common/param/HasInputCol.java | 0
.../apache/flink/ml/common/param/HasInputCols.java | 0
.../apache/flink/ml/common/param/HasLabelCol.java | 0
.../flink/ml/common/param/HasLearningRate.java | 0
.../ml/common/param/HasMaxAllowedModelDelayMs.java | 0
.../apache/flink/ml/common/param/HasMaxIter.java | 0
.../flink/ml/common/param/HasModelVersionCol.java | 0
.../flink/ml/common/param/HasMultiClass.java | 0
.../flink/ml/common/param/HasNumFeatures.java | 0
.../apache/flink/ml/common/param/HasOutputCol.java | 0
.../flink/ml/common/param/HasOutputCols.java | 0
.../flink/ml/common/param/HasPredictionCol.java | 0
.../flink/ml/common/param/HasRawPredictionCol.java | 0
.../org/apache/flink/ml/common/param/HasReg.java | 0
.../flink/ml/common/param/HasRelativeError.java | 0
.../org/apache/flink/ml/common/param/HasSeed.java | 0
.../org/apache/flink/ml/common/param/HasTol.java | 0
.../apache/flink/ml/common/param/HasWeightCol.java | 0
flink-ml-uber/pom.xml | 7 ++
pom.xml | 1 +
tools/ci/stage.sh | 2 +
44 files changed, 429 insertions(+), 106 deletions(-)
rename
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/{LogisticRegressionModelData.java
=> LogisticRegressionModelDataUtil.java} (74%)
copy {flink-ml-tests => flink-ml-servable-lib}/pom.xml (67%)
create mode 100644
flink-ml-servable-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelData.java
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelParams.java
(94%)
create mode 100644
flink-ml-servable-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServable.java
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasBatchStrategy.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasCategoricalCols.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasDecayFactor.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasElasticNet.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasFeaturesCol.java
(92%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasFlatten.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasGlobalBatchSize.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasHandleInvalid.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasInputCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasInputCols.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasLabelCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasLearningRate.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasMaxAllowedModelDelayMs.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasMaxIter.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasModelVersionCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasMultiClass.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasNumFeatures.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasOutputCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasOutputCols.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasPredictionCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasRawPredictionCol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasReg.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasRelativeError.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasSeed.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasTol.java
(100%)
rename {flink-ml-lib =>
flink-ml-servable-lib}/src/main/java/org/apache/flink/ml/common/param/HasWeightCol.java
(100%)
