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/09/27 08:48:21 UTC
[flink-ml] branch master updated (d224f56 -> b77aafa)

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 d224f56  [FLINK-28806] Add Transformer and Estimator for IDF
     add b77aafa  [FLINK-28906] Support windowing in AgglomerativeClustering

No new revisions were added by this update.

Summary of changes:
 .../clustering/agglomerativeclustering.md          |  19 ++-
 .../ml/common/datastream/DataStreamUtils.java      |  70 ++++++++
 .../ml/common/window/CountTumblingWindows.java     |  64 +++++++
 .../ml/common/window/EventTimeSessionWindows.java  |  64 +++++++
 .../ml/common/window/EventTimeTumblingWindows.java |  64 +++++++
 .../flink/ml/common/window/GlobalWindows.java      |  39 ++---
 .../window/ProcessingTimeSessionWindows.java       |  64 +++++++
 .../window/ProcessingTimeTumblingWindows.java      |  64 +++++++
 .../org/apache/flink/ml/common/window/Windows.java |  12 +-
 .../org/apache/flink/ml/param/WindowsParam.java    |  95 +++++++++++
 .../java/org/apache/flink/ml/api/StageTest.java    |  50 ++++++
 .../apache/flink/ml/common/window/WindowsTest.java | 190 +++++++++++++++++++++
 .../AgglomerativeClustering.java                   | 108 ++++++------
 .../AgglomerativeClusteringParams.java             |   3 +-
 .../{HasPredictionCol.java => HasWindows.java}     |  27 +--
 .../ml/clustering/AgglomerativeClusteringTest.java | 131 ++++++++++++--
 flink-ml-python/pyflink/ml/core/param.py           |  16 +-
 .../pyflink/ml/core/tests/test_param.py            |  19 ++-
 .../pyflink/ml/core/tests/test_stage.py            |  49 +++++-
 flink-ml-python/pyflink/ml/core/windows.py         | 150 ++++++++++++++++
 flink-ml-python/pyflink/ml/core/wrapper.py         |  65 ++++++-
 .../ml/lib/clustering/agglomerativeclustering.py   |  22 ++-
 .../tests/test_agglomerativeclustering.py          | 136 +++++++++++++--
 flink-ml-python/pyflink/ml/lib/param.py            |  25 ++-
 24 files changed, 1394 insertions(+), 152 deletions(-)
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/common/window/CountTumblingWindows.java
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/common/window/EventTimeSessionWindows.java
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/common/window/EventTimeTumblingWindows.java
 copy flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/EpochRecord.java => flink-ml-core/src/main/java/org/apache/flink/ml/common/window/GlobalWindows.java (56%)
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/common/window/ProcessingTimeSessionWindows.java
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/common/window/ProcessingTimeTumblingWindows.java
 copy flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java => flink-ml-core/src/main/java/org/apache/flink/ml/common/window/Windows.java (75%)
 create mode 100644 flink-ml-core/src/main/java/org/apache/flink/ml/param/WindowsParam.java
 create mode 100644 flink-ml-core/src/test/java/org/apache/flink/ml/common/window/WindowsTest.java
 copy flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/{HasPredictionCol.java => HasWindows.java} (62%)
 create mode 100644 flink-ml-python/pyflink/ml/core/windows.py