[hotfix][python] move the method _from_java_type_wrapper from linalg.py to wrapper.py

Revert "[hotfix][python] Fix the _from_java_type_wrapper is not imported"

This reverts commit dd161698

[hotfix][python] Fix the _from_java_type_wrapper is not imported

[FLINK-27096] Add LabeledPointWithWeightGenerator and Benchmark Configuration for KMeans and NaiveBayes

This closes #100.

[FLINK-27294] Add Transformer for BinaryClassificationEvaluator

This closes #86.

[FLINK-27404][python] Add algorithms completeness test in ML Python API

This closes #99.

[FLINK-27403][ml][python] Align existing feature engineering algorithms in ML Python API

This closes #98.

[hotfix] Fix finding buckets error in Bucketizer (#96)

This closes #96.

[FLINK-27091] Add Transformer and Estimator of LinearSVC

This closes #93.

[hotfix] Bump dependency versions

This closes #94.

[FLINK-27096] Add a script to visualize benchmark results

This PR also enriches benchmark result file's content with input parameters

This closes #87.

[FLINK-27093] Add Transformer and Estimator for LinearRegression

This closes #90.

[FLINK-26269][python] Add clustering algorithm support for KMeans in ML Python API

This closes #91.

[hotfix] Update .asf.yaml file to disable the merge button and update collaborators etc.

This closes #92.

Merge pull request #89 from lindong28/improve-github-action

[hotfix] Suppress the output of downloading messages in the github action log

This closes #89.

[hotfix] Suppress the output of downloading messages in the github action log

[FLINK-26268][ml][python] Add classfication algorithm support for LogisticRegression, KNN and NaiveBayes in ML Python API

This closes #88.

Bump junit from 4.12 to 4.13.1 (#79)

Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1.

Signed-off-by: dependabot[bot] <support@github.com>

[FLINK-27072] Add Transformer for Bucketizer

[hotfix] Reorganize HasHandleInvalid param in StringIndexer, OneHotEncoder and VectorAssembler

[Flink 26443] Add benchmark framework

This closes #71.

[hotfix] Use inputCol and outputCol in MinMaxScaler and StandardScaler

[hotfix] Rename testFeaturePredictionParam to testOutputSchema in unit test

[FLINK-26626] Add Transformer and Estimator of StandardScaler

[FLINK-25616] Add Transformer for VectorAssembler

This closes #56.

[FLINK-26904] Update Stage::load to use StreamTableEnvironment

This closes #76.

[FLINK-26100] Add link to document website in README

This PR adds a link to Flink ML's document website in README.md. The added content is referenced from Flink repo's README.

This closes #75.

[FLINK-26313] Add Transformer and Estimator of OnlineKMeans

This closes #70.

[FLINK-25527] Add Transformer and Estimator for StringIndexer

This closes #52.

[FLINK-25552] Add Estimator and Transformer for MinMaxScaler

This closes #54.

[hotfix] Fix document minor error in docs.README.md

This closes #72.

[FLINK-26404] Support non-local file systems

This closes #68.

[FLINK-26263] (followup) Check data size in LogisticRegression

This closes #66.

[FLINK-26267][ml][python] Add common params interface in ML Python API

This closes #65.

[FLINK-26266][ml][python] Support Vector and Matrix in ML Python API

This closes #64.

[FLINK-26263] Check data size in LogisticRegression

This closes #63.

[FLINK-26100][docs] Add doc for ops & key concepts (#62)

This closes #62.

[FLINK-26100][docs] Set up Flink ML Document Website

This closes #58.

[hotfix] Remove redundant directories

This closes #55.

[hotfix] Add scala suffix for flink-ml-uber dependency and flink-ml-lib as a dependency of flink-ml-uber

[hotfix][python] Update setup.py to throw error if python version > 3.8

This closes #51.

[hotfix] Add scala version as suffix of all modules

[hotfix] Update README.md, NOTICE and license of blas in flink-ml-uber

[release] Update version to 2.1-SNAPSHOT

[hotfix] Remove scala target and fix script errors

1. The release profile must be called apache-release to also deploy
source and javadoc jars.
2. Remove the command related to python whl package.
3. Always relies on scala 2.12.

[hotfix] Add the NOTICE file

This closes #45.

Revert "[release] Update version to 2.1-SNAPSHOT"

This reverts commit ac7da66c0e30ff925d1465d9d1251a38c05ddc08.

[hotfix] Add scripts to build and release python artifacts

This closes #44.

[release] Update version to 2.1-SNAPSHOT

Prepares Flink ML for 2.0.0 release

This commit makes the following changes:
- Adds scripts under tools/releasing
- Updates Flink ML version to 2.0-SNAPSHOT
- Includes flink-ml-uber in the pom.xml
- Updates flink-ml-uber/pom.xml to include the core module and the iteration module
- Updates the release profile in pom.xml to follow flink-statefun's practice
- Removes flink-ml-examples

[FLINK-25394] Upgrade log4j to 2.17.0

This closes #42.

[hotfix][iteration] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

This closes #41.

[FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

This closes #20.

[FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

This closes #24.

[FLINK-24556] Make model data pojo for naive bayes, kmeans and logistic regression

This closes #28.

[hotfix] Reformat naive bayes, kmeans and logistic regression

[FLINK-24556] Add Estimator and Transformer for logistic regression

[FLINK-24845] Add allreduce utility function in FlinkML

This closes #30.

[FLINK-24955] Add Estimator and Transformer for One Hot Encoder

This closes #37.

[hotfix] Move infra from flink-ml-lib to flink-ml-core

This closes #39.

[FLINK-24817] Add Estimator and Transformer for Naive Bayes

This closes #32.

[FLINK-25120][python] Add many kinds of checks in ML Python API

This closes #40.

[FLINK-25120][python] Fix some type annotations

This closes #40.

[FLINK-24933][python] Support ML Python API to implement FLIP-173 and FLP-174

This closes #36.

[hotfix] Rename flink-ml-api to flink-ml-core

This closes #38.

[hotfix] Cache records when processing elements rather than only in snapshot func

[hotfix] Fix nullpointer exception when broadcast variables are cleaned

[FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

This closes #27.

[FLINK-22915][FLIP-173] Updates the static load(...) method of Stage subclasses to take StreamExecutionEnvironment as parameter

[FLINK-22915][FLIP-173] Updates Model::setModelData(...) to return the Model instance itself

This closes #33.

[FLINK-24354][FLIP-174] Updates WithParams::set(...) to throw Exception if the given param is not defined on this instance

This closes #35.

[hotfix] Mark BroadcastUtils as internal

[hotfix][iteration] Return more fine-grained operator class for the WrapperFactory

[FLINK-24842][iteration] Make outputs depends on tails for the iteration body

This closes #31.

[FLINK-24808][iteration] Support IterationListener for per-round operators

This closes #26.

[hotfix][iteration] Fix the bad compile due to changes of state

[FLINK-24807][iteration] Not start logging at the head operator if the barrier feed back first

This closes #25.

[FLINK-24807][iteration] Support raw operator state

[FLINK-24807][iteration] not emit CoordinatorCheckpointEvent after terminating

Currently the HeadCoordinator would emit CoordinatorCheckpointEvent to
the tasks so that the GloballyAlignedEvent would not be interleave with
the checkpoint barrier. Howver, if the tasks are finished and we
continue emitting the event, the checkpoint would fail due to there
are failed operator events. To address this issue, we would stop
emitting CoordinatorCheckpointEvent after the head operator is terminating,
namely it received the GloballyAlignedEvent marking terminating.

[FLINK-24807][iteration] Add per-round checkpoint IT case

[hotfix][iteration] Rename the all-round checkpoint test to be it case

[FLINK-24807][iteration] Stores the state for per-round wrapper

[FLINK-24807][iteration] Support snapshot the ReplayOperator

[FLINK-24729][iteration] Support iteration with mixed operator life-cycle

This closes #23.

[hotfix][iteration] Fixes the wrong type for criteria merger

[FLINK-24722][iteration] Fix the issues in supporting keyed stream inside the iteration body

This closes #22.

[FLINK-24354][FLIP-174] Improve the WithParams interface

[FLINK-24354][FLIP-174] Remove old param-related classes

[hotfix] Remove those library infra classes that need to be revisited

This closes #19.

[FLINK-24279] support withBroadcast in DataStream

This closes #18.

[FLINK-24655][iteration] Add ITCase for the checkpoint and failover

This closes #17.

[FLINK-24655][iteration] Do not rely on the precedent tasks to insert epoch watermark

If the finished and failover, then it would be skipped and would not
insert the epoch watermark again.

[FLINK-24655][iteration] Skip the repeat round for all-round operator

[FLINK-24655][iteration] Support the checkpoints for the iteration

[FLINK-24655][iteration] Support snapshot the feedback records on checkpoint

[FLINK-24655][iteration] Make head operator aligned with coordinator for each checkpoint

[hotfix][iteration] Simplify the head operator test

[FLINK-24655][iteration] HeadOperator waits for MAX_WATERMARK iterates back before terminating.

This is a basis for the checkpoint since for checkpoints
with feedback edges, we would need to also include the
feedback records into snapshot, thus if we want to make
sure all the checkpoints before the terminated globally
aligned events get done, we have to wait for one more round.

[FLINK-24653][iteration] Support per-round operators inside the iteration

[hotfix][iteration] Merge the IterationFactory and Iterations