Skip to content

[SPARK-23975][ML]Allow Clustering to take Arrays of Double as input features #21081

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
lu-wang-dl wants to merge 9 commits into from
Closed

[SPARK-23975][ML]Allow Clustering to take Arrays of Double as input features #21081

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
ed890d3
add Array input support for KMeans
lu-wang-dl Apr 16, 2018
badb0cc
remove redundent code
lu-wang-dl Apr 16, 2018
6d222a3
make sure the code works for Float type and add the unit test
lu-wang-dl Apr 16, 2018
009b918
consolidating featuretovector
lu-wang-dl Apr 19, 2018
cd988c7
change featureToVector to KMeanParams and add the scala docs
lu-wang-dl Apr 20, 2018
3ffb322
change featureToVector and validateSchema to private functions
lu-wang-dl Apr 23, 2018
fee36ad
Merge branch 'master' of https://github.com/apache/spark into SPARK-2…
lu-wang-dl Apr 23, 2018
3e012fb
move featureToVector to util, so that other methods could use it to a…
lu-wang-dl Apr 23, 2018
c4e1a51
fix the comments and correct code style
lu-wang-dl Apr 23, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
remove redundent code
  • Loading branch information
@lu-wang-dl
lu-wang-dl committed Apr 16, 2018
commit badb0cc5ca6ca69bb8e8fc0fce5ea05a4100bca0
2 changes: 0 additions & 2 deletions mllib/src/main/scala/org/apache/spark/ml/clustering/KMeans.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -322,8 +322,6 @@ class KMeans @Since("1.5.0") (
@Since("1.5.0")
def setSeed(value: Long): this.type = set(seed, value)

case class SeqDouble(value: Seq[Double])

@Since("2.0.0")
override def fit(dataset: Dataset[_]): KMeansModel = {
transformSchema(dataset.schema, logging = true)
Expand Down