Skip to content

Commit b6e06e8

Browse files
committed
formatting, nits
1 parent 97c96b6 commit b6e06e8

File tree

3 files changed

+4
-8
lines changed

3 files changed

+4
-8
lines changed

mllib/src/test/scala/org/apache/spark/ml/clustering/BisectingKMeansSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,7 @@ import org.apache.spark.ml.param.ParamMap
2222
import org.apache.spark.ml.util.{DefaultReadWriteTest, MLTest, MLTestingUtils}
2323
import org.apache.spark.sql.Dataset
2424

25-
class BisectingKMeansSuite
26-
extends MLTest with DefaultReadWriteTest {
25+
class BisectingKMeansSuite extends MLTest with DefaultReadWriteTest {
2726

2827
import Encoders._
2928

@@ -106,6 +105,7 @@ class BisectingKMeansSuite
106105
testTransformerByGlobalCheckFunc[Vector](dataset.toDF(), model,
107106
"features", predictionColName) { rows =>
108107
val clusters = rows.map(_.getAs[Int](predictionColName)).toSet
108+
assert(clusters.size === k)
109109
assert(clusters === Set(0, 1, 2, 3, 4))
110110
assert(model.computeCost(dataset) < 0.1)
111111
assert(model.hasParent)

mllib/src/test/scala/org/apache/spark/ml/clustering/GaussianMixtureSuite.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,7 @@ import org.apache.spark.ml.util.TestingUtils._
2626
import org.apache.spark.sql.{Dataset, Row}
2727

2828

29-
class GaussianMixtureSuite extends MLTest
30-
with DefaultReadWriteTest {
29+
class GaussianMixtureSuite extends MLTest with DefaultReadWriteTest {
3130

3231
import testImplicits._
3332
import Encoders._

mllib/src/test/scala/org/apache/spark/ml/clustering/LDASuite.scala

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,6 @@ import org.apache.spark.ml.linalg.{Vector, Vectors}
2323
import org.apache.spark.ml.util.{DefaultReadWriteTest, MLTest, MLTestingUtils}
2424
import org.apache.spark.ml.util.TestingUtils._
2525
import org.apache.spark.sql._
26-
import org.apache.spark.sql.catalyst.encoders.ExpressionEncoder
27-
2826

2927
object LDASuite {
3028
def generateLDAData(
@@ -62,8 +60,7 @@ object LDASuite {
6260
class LDASuite extends MLTest with DefaultReadWriteTest {
6361

6462
import testImplicits._
65-
66-
implicit val vectorEncoder = ExpressionEncoder[Vector]()
63+
import Encoders._
6764

6865
val k: Int = 5
6966
val vocabSize: Int = 30

0 commit comments

Comments
 (0)