This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git.
from eeccb82 [FLINK-24845] Add allreduce utility function in FlinkML
add 0f20eeb [FLINK-24556] Add Estimator and Transformer for logistic
regression
add a7a0b44 [hotfix] Reformat naive bayes, kmeans and logistic regression
new d36fe8f [FLINK-24556] Make model data pojo for naive bayes, kmeans
and logistic regression
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-core/pom.xml | 4 +-
.../ml/common/datastream/DataStreamUtils.java | 66 +++
.../ml/common/datastream/EndOfStreamWindows.java | 5 +-
.../datastream/MapPartitionFunctionWrapper.java | 67 ---
.../ml/common/feature/LabeledPointWithWeight.java | 63 +++
...axIterationNum.java => TerminateOnMaxIter.java} | 13 +-
...rationNum.java => TerminateOnMaxIterOrTol.java} | 43 +-
.../main/java/org/apache/flink/ml/linalg/BLAS.java | 21 +
.../org/apache/flink/ml/linalg/DenseVector.java | 4 +
.../org/apache/flink/ml/util/ReadWriteUtils.java | 6 +-
.../ml/common/datastream/DataStreamUtilsTest.java | 75 ++++
.../java/org/apache/flink/ml/linalg/BLASTest.java | 64 +++
.../logisticregression/LogisticGradient.java | 97 +++++
.../logisticregression/LogisticRegression.java | 458 +++++++++++++++++++++
.../LogisticRegressionModel.java | 173 ++++++++
.../LogisticRegressionModelData.java | 111 +++++
.../LogisticRegressionModelParams.java | 20 +-
.../LogisticRegressionParams.java} | 37 +-
.../ml/classification/naivebayes/NaiveBayes.java | 54 +--
.../classification/naivebayes/NaiveBayesModel.java | 10 +-
.../naivebayes/NaiveBayesModelData.java | 85 ++--
.../apache/flink/ml/clustering/kmeans/KMeans.java | 19 +-
.../flink/ml/clustering/kmeans/KMeansModel.java | 151 +++----
.../ml/clustering/kmeans/KMeansModelData.java | 77 ++--
.../ml/clustering/kmeans/KMeansModelParams.java | 2 +-
.../flink/ml/clustering/kmeans/KMeansParams.java | 2 +-
.../flink/ml/common/param/HasDistanceMeasure.java | 2 +-
.../{HasMaxIter.java => HasGlobalBatchSize.java} | 22 +-
.../flink/ml/common/param/HasHandleInvalid.java | 2 +-
.../apache/flink/ml/common/param/HasLabelCol.java | 2 +-
.../{HasInputCols.java => HasLearningRate.java} | 24 +-
.../apache/flink/ml/common/param/HasMaxIter.java | 2 +-
.../{HasHandleInvalid.java => HasMultiClass.java} | 38 +-
.../flink/ml/common/param/HasPredictionCol.java | 2 +-
.../{HasLabelCol.java => HasRawPredictionCol.java} | 18 +-
.../common/param/{HasMaxIter.java => HasReg.java} | 19 +-
.../param/{HasFeaturesCol.java => HasTol.java} | 25 +-
.../param/{HasLabelCol.java => HasWeightCol.java} | 19 +-
.../ml/feature/onehotencoder/OneHotEncoder.java | 16 +-
.../logisticregression/LogisticRegressionTest.java | 281 +++++++++++++
.../org/apache/flink/ml/clustering/KMeansTest.java | 49 ++-
flink-ml-tests/pom.xml | 7 +
.../BoundedAllRoundStreamIterationITCase.java | 6 +-
.../operators/RoundBasedTerminationCriteria.java | 48 ---
44 files changed, 1801 insertions(+), 508 deletions(-)
delete mode 100644
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
create mode 100644
flink-ml-core/src/main/java/org/apache/flink/ml/common/feature/LabeledPointWithWeight.java
copy
flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/{TerminateOnMaxIterationNum.java
=> TerminateOnMaxIter.java} (85%)
rename
flink-ml-core/src/main/java/org/apache/flink/ml/common/iteration/{TerminateOnMaxIterationNum.java
=> TerminateOnMaxIterOrTol.java} (56%)
create mode 100644
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java
create mode 100644
flink-ml-core/src/test/java/org/apache/flink/ml/linalg/BLASTest.java
create mode 100644
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticGradient.java
create mode 100644
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegression.java
create mode 100644
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModel.java
create mode 100644
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelData.java
copy
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/allround/EpochAware.java
=>
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelParams.java
(63%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/{naivebayes/NaiveBayesParams.java
=> logisticregression/LogisticRegressionParams.java} (52%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasMaxIter.java =>
HasGlobalBatchSize.java} (66%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasInputCols.java
=> HasLearningRate.java} (64%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasHandleInvalid.java
=> HasMultiClass.java} (57%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasLabelCol.java
=> HasRawPredictionCol.java} (69%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasMaxIter.java =>
HasReg.java} (70%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasFeaturesCol.java
=> HasTol.java} (66%)
copy
flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasLabelCol.java
=> HasWeightCol.java} (69%)
create mode 100644
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionTest.java
delete mode 100644
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/RoundBasedTerminationCriteria.java
