You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2022/03/29 10:32:29 UTC
[flink-ml] branch master updated (8571317 -> d6d0753)
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 8571317 [FLINK-25527] Add Transformer and Estimator for StringIndexer
add d6d0753 [FLINK-26313] Add Transformer and Estimator of OnlineKMeans
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/flink/ml/api/Stage.java | 2 +-
.../ml/common/broadcast/BroadcastContext.java | 2 +-
.../common/distance/EuclideanDistanceMeasure.java | 3 +
.../apache/flink/ml/clustering/kmeans/KMeans.java | 108 +++--
.../flink/ml/clustering/kmeans/KMeansModel.java | 23 +-
.../ml/clustering/kmeans/KMeansModelData.java | 78 +++-
.../ml/clustering/kmeans/KMeansModelParams.java | 5 +-
.../flink/ml/clustering/kmeans/KMeansParams.java | 1 -
.../flink/ml/clustering/kmeans/OnlineKMeans.java | 400 +++++++++++++++++
.../ml/clustering/kmeans/OnlineKMeansModel.java | 214 +++++++++
.../kmeans/OnlineKMeansParams.java} | 17 +-
.../{HasFeaturesCol.java => HasBatchStrategy.java} | 23 +-
.../{HasLearningRate.java => HasDecayFactor.java} | 23 +-
.../org/apache/flink/ml/clustering/KMeansTest.java | 43 +-
.../flink/ml/clustering/OnlineKMeansTest.java | 498 +++++++++++++++++++++
.../apache/flink/ml/util/InMemorySinkFunction.java | 82 ++++
.../flink/ml/util/InMemorySourceFunction.java | 83 ++++
17 files changed, 1490 insertions(+), 115 deletions(-)
create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java
create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java
copy flink-ml-lib/src/main/java/org/apache/flink/ml/{feature/stringindexer/IndexToStringModelParams.java => clustering/kmeans/OnlineKMeansParams.java} (62%)
copy flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasFeaturesCol.java => HasBatchStrategy.java} (66%)
copy flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasLearningRate.java => HasDecayFactor.java} (69%)
create mode 100644 flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java
create mode 100644 flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySinkFunction.java
create mode 100644 flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySourceFunction.java