[flink-ml] branch master updated (01950cb -> 212be99)

[ga...@apache.org]

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 01950cb  [FLINK-22915][FLIP-173] Updates the static load(...) method of Stage subclasses to take StreamExecutionEnvironment as parameter
     add 212be99  [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

No new revisions were added by this update.

Summary of changes:
 .../DistanceMeasure.java}                          |  30 +-
 .../ml/distance/EuclideanDistanceMeasure.java      |  32 +-
 .../org/apache/flink/ml/linalg/DenseVector.java    |  46 +--
 .../java/org/apache/flink/ml/linalg/Vector.java    |  19 +-
 .../java/org/apache/flink/ml/linalg/Vectors.java   |  17 +-
 .../ml/linalg/typeinfo/DenseVectorSerializer.java  | 137 +++++++++
 .../ml/linalg/typeinfo/DenseVectorTypeInfo.java    |  70 ++---
 .../typeinfo/DenseVectorTypeInfoFactory.java       |  30 +-
 .../org/apache/flink/ml/util/ReadWriteUtils.java   |  35 ++-
 .../org/apache/flink/ml/api/core/StageTest.java    |   2 +-
 flink-ml-lib/pom.xml                               |  22 +-
 .../apache/flink/ml/clustering/kmeans/KMeans.java  | 337 +++++++++++++++++++++
 .../flink/ml/clustering/kmeans/KMeansModel.java    | 214 +++++++++++++
 .../ml/clustering/kmeans/KMeansModelData.java      |  97 ++++++
 .../ml/clustering/kmeans/KMeansModelParams.java    |  46 ++-
 .../flink/ml/clustering/kmeans/KMeansParams.java   |  49 +++
 .../ml/common/datastream/EndOfStreamWindows.java   |  71 +++++
 .../datastream/MapPartitionFunctionWrapper.java    |  67 ++++
 .../flink/ml/common/datastream/TableUtils.java     |  41 +++
 .../common/iteration/ForwardInputsOfLastRound.java |  60 ++++
 .../iteration/TerminateOnMaxIterationNum.java      |  31 +-
 .../flink/ml/common/param/HasDistanceMeasure.java  |  35 ++-
 .../flink/ml/common/param/HasFeaturesCol.java      |  27 +-
 .../apache/flink/ml/common/param/HasMaxIter.java   |  26 +-
 .../flink/ml/common/param/HasPredictionCol.java    |  34 ++-
 .../org/apache/flink/ml/common/param/HasSeed.java  |  28 +-
 .../org/apache/flink/ml/clustering/KMeansTest.java | 259 ++++++++++++++++
 27 files changed, 1621 insertions(+), 241 deletions(-)
 copy flink-ml-api/src/main/java/org/apache/flink/ml/{param/ParamValidator.java => distance/DistanceMeasure.java} (52%)
 copy flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/FailingMap.java => flink-ml-api/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java (52%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/event/CoordinatorCheckpointEvent.java => flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java (52%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationID.java => flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vector.java (70%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationID.java => flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vectors.java (71%)
 create mode 100644 flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java
 copy flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/typeinfo/CacheElementTypeInfo.java => flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java (58%)
 copy flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/CollectSink.java => flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java (54%)
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModelData.java
 copy flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/EpochRecord.java => flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModelParams.java (51%)
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansParams.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/EndOfStreamWindows.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/TableUtils.java
 create mode 100644 flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/ForwardInputsOfLastRound.java
 copy flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/RoundBasedTerminationCriteria.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/iteration/TerminateOnMaxIterationNum.java (60%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/ProxyKeySelector.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDistanceMeasure.java (50%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasFeaturesCol.java (55%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasMaxIter.java (57%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/ProxyKeySelector.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasPredictionCol.java (52%)
 copy flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/state/StateNamePrefix.java => flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasSeed.java (58%)
 create mode 100644 flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java