Skip to content

Commit 5f14cde

Browse files
mengxrJoshRosen
mengxr
authored and
JoshRosen
committed
[SPARK-4373][MLLIB] fix MLlib maven tests
We want to make sure there is at most one spark context inside the same jvm. JoshRosen Author: Xiangrui Meng <meng@databricks.com> Closes #3235 from mengxr/SPARK-4373 and squashes the following commits: 6574b69 [Xiangrui Meng] rename LocalSparkContext to MLlibTestSparkContext 913d48d [Xiangrui Meng] make sure there is at most one spark context inside the same jvm (cherry picked from commit 23f5bdf) Signed-off-by: Josh Rosen <joshrosen@databricks.com>
1 parent 675df2a commit 5f14cde

36 files changed

+108
-82
lines changed

‎mllib/src/test/scala/org/apache/spark/ml/classification/LogisticRegressionSuite.scala

Lines changed: 17 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,16 +20,24 @@ package org.apache.spark.ml.classification
2020
import org.scalatest.FunSuite
2121

2222
import org.apache.spark.mllib.classification.LogisticRegressionSuite.generateLogisticInput
23-
import org.apache.spark.mllib.util.LocalSparkContext
24-
import org.apache.spark.sql.SchemaRDD
23+
import org.apache.spark.mllib.util.MLlibTestSparkContext
24+
import org.apache.spark.sql.{SQLContext, SchemaRDD}
2525

26-
class LogisticRegressionSuite extends FunSuite with LocalSparkContext {
26+
class LogisticRegressionSuite extends FunSuite with MLlibTestSparkContext {
2727

28-
import sqlContext._
28+
@transient var sqlContext: SQLContext = _
29+
@transient var dataset: SchemaRDD = _
2930

30-
val dataset: SchemaRDD = sc.parallelize(generateLogisticInput(1.0, 1.0, 100, 42), 2)
31+
override def beforeAll(): Unit = {
32+
super.beforeAll()
33+
sqlContext = new SQLContext(sc)
34+
dataset = sqlContext.createSchemaRDD(
35+
sc.parallelize(generateLogisticInput(1.0, 1.0, 100, 42), 2))
36+
}
3137

3238
test("logistic regression") {
39+
val sqlContext = this.sqlContext
40+
import sqlContext._
3341
val lr = new LogisticRegression
3442
val model = lr.fit(dataset)
3543
model.transform(dataset)
@@ -38,6 +46,8 @@ class LogisticRegressionSuite extends FunSuite with LocalSparkContext {
3846
}
3947

4048
test("logistic regression with setters") {
49+
val sqlContext = this.sqlContext
50+
import sqlContext._
4151
val lr = new LogisticRegression()
4252
.setMaxIter(10)
4353
.setRegParam(1.0)
@@ -48,6 +58,8 @@ class LogisticRegressionSuite extends FunSuite with LocalSparkContext {
4858
}
4959

5060
test("logistic regression fit and transform with varargs") {
61+
val sqlContext = this.sqlContext
62+
import sqlContext._
5163
val lr = new LogisticRegression
5264
val model = lr.fit(dataset, lr.maxIter -> 10, lr.regParam -> 1.0)
5365
model.transform(dataset, model.threshold -> 0.8, model.scoreCol -> "probability")

‎mllib/src/test/scala/org/apache/spark/ml/tuning/CrossValidatorSuite.scala

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,14 +22,19 @@ import org.scalatest.FunSuite
2222
import org.apache.spark.ml.classification.LogisticRegression
2323
import org.apache.spark.ml.evaluation.BinaryClassificationEvaluator
2424
import org.apache.spark.mllib.classification.LogisticRegressionSuite.generateLogisticInput
25-
import org.apache.spark.mllib.util.LocalSparkContext
26-
import org.apache.spark.sql.SchemaRDD
25+
import org.apache.spark.mllib.util.MLlibTestSparkContext
26+
import org.apache.spark.sql.{SQLContext, SchemaRDD}
2727

28-
class CrossValidatorSuite extends FunSuite with LocalSparkContext {
28+
class CrossValidatorSuite extends FunSuite with MLlibTestSparkContext {
2929

30-
import sqlContext._
30+
@transient var dataset: SchemaRDD = _
3131

32-
val dataset: SchemaRDD = sc.parallelize(generateLogisticInput(1.0, 1.0, 100, 42), 2)
32+
override def beforeAll(): Unit = {
33+
super.beforeAll()
34+
val sqlContext = new SQLContext(sc)
35+
dataset = sqlContext.createSchemaRDD(
36+
sc.parallelize(generateLogisticInput(1.0, 1.0, 100, 42), 2))
37+
}
3338

3439
test("cross validation with logistic regression") {
3540
val lr = new LogisticRegression

‎mllib/src/test/scala/org/apache/spark/mllib/classification/LogisticRegressionSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import org.scalatest.Matchers
2525

2626
import org.apache.spark.mllib.linalg.Vectors
2727
import org.apache.spark.mllib.regression._
28-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
28+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2929
import org.apache.spark.mllib.util.TestingUtils._
3030

3131
object LogisticRegressionSuite {
@@ -57,7 +57,7 @@ object LogisticRegressionSuite {
5757
}
5858
}
5959

60-
class LogisticRegressionSuite extends FunSuite with LocalSparkContext with Matchers {
60+
class LogisticRegressionSuite extends FunSuite with MLlibTestSparkContext with Matchers {
6161
def validatePrediction(
6262
predictions: Seq[Double],
6363
input: Seq[LabeledPoint],

‎mllib/src/test/scala/org/apache/spark/mllib/classification/NaiveBayesSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import org.scalatest.FunSuite
2424
import org.apache.spark.SparkException
2525
import org.apache.spark.mllib.linalg.Vectors
2626
import org.apache.spark.mllib.regression.LabeledPoint
27-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
27+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2828

2929
object NaiveBayesSuite {
3030

@@ -60,7 +60,7 @@ object NaiveBayesSuite {
6060
}
6161
}
6262

63-
class NaiveBayesSuite extends FunSuite with LocalSparkContext {
63+
class NaiveBayesSuite extends FunSuite with MLlibTestSparkContext {
6464

6565
def validatePrediction(predictions: Seq[Double], input: Seq[LabeledPoint]) {
6666
val numOfPredictions = predictions.zip(input).count {

‎mllib/src/test/scala/org/apache/spark/mllib/classification/SVMSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import org.scalatest.FunSuite
2626
import org.apache.spark.SparkException
2727
import org.apache.spark.mllib.linalg.Vectors
2828
import org.apache.spark.mllib.regression._
29-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
29+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
3030

3131
object SVMSuite {
3232

@@ -58,7 +58,7 @@ object SVMSuite {
5858

5959
}
6060

61-
class SVMSuite extends FunSuite with LocalSparkContext {
61+
class SVMSuite extends FunSuite with MLlibTestSparkContext {
6262

6363
def validatePrediction(predictions: Seq[Double], input: Seq[LabeledPoint]) {
6464
val numOffPredictions = predictions.zip(input).count { case (prediction, expected) =>

‎mllib/src/test/scala/org/apache/spark/mllib/clustering/KMeansSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@ import scala.util.Random
2222
import org.scalatest.FunSuite
2323

2424
import org.apache.spark.mllib.linalg.{Vector, Vectors}
25-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
25+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2626
import org.apache.spark.mllib.util.TestingUtils._
2727

28-
class KMeansSuite extends FunSuite with LocalSparkContext {
28+
class KMeansSuite extends FunSuite with MLlibTestSparkContext {
2929

3030
import org.apache.spark.mllib.clustering.KMeans.{K_MEANS_PARALLEL, RANDOM}
3131

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/AreaUnderCurveSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ package org.apache.spark.mllib.evaluation
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323
import org.apache.spark.mllib.util.TestingUtils._
2424

25-
class AreaUnderCurveSuite extends FunSuite with LocalSparkContext {
25+
class AreaUnderCurveSuite extends FunSuite with MLlibTestSparkContext {
2626
test("auc computation") {
2727
val curve = Seq((0.0, 0.0), (1.0, 1.0), (2.0, 3.0), (3.0, 0.0))
2828
val auc = 4.0

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/BinaryClassificationMetricsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ package org.apache.spark.mllib.evaluation
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323
import org.apache.spark.mllib.util.TestingUtils._
2424

25-
class BinaryClassificationMetricsSuite extends FunSuite with LocalSparkContext {
25+
class BinaryClassificationMetricsSuite extends FunSuite with MLlibTestSparkContext {
2626

2727
def cond1(x: (Double, Double)): Boolean = x._1 ~= (x._2) absTol 1E-5
2828

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/MulticlassMetricsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,9 @@ package org.apache.spark.mllib.evaluation
2020
import org.scalatest.FunSuite
2121

2222
import org.apache.spark.mllib.linalg.Matrices
23-
import org.apache.spark.mllib.util.LocalSparkContext
23+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2424

25-
class MulticlassMetricsSuite extends FunSuite with LocalSparkContext {
25+
class MulticlassMetricsSuite extends FunSuite with MLlibTestSparkContext {
2626
test("Multiclass evaluation metrics") {
2727
/*
2828
* Confusion matrix for 3-class classification with total 9 instances:

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/MultilabelMetricsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ package org.apache.spark.mllib.evaluation
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323
import org.apache.spark.rdd.RDD
2424

25-
class MultilabelMetricsSuite extends FunSuite with LocalSparkContext {
25+
class MultilabelMetricsSuite extends FunSuite with MLlibTestSparkContext {
2626
test("Multilabel evaluation metrics") {
2727
/*
2828
* Documents true labels (5x class0, 3x class1, 4x class2):

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/RankingMetricsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,9 @@ package org.apache.spark.mllib.evaluation
2020
import org.scalatest.FunSuite
2121

2222
import org.apache.spark.mllib.util.TestingUtils._
23-
import org.apache.spark.mllib.util.LocalSparkContext
23+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2424

25-
class RankingMetricsSuite extends FunSuite with LocalSparkContext {
25+
class RankingMetricsSuite extends FunSuite with MLlibTestSparkContext {
2626
test("Ranking metrics: map, ndcg") {
2727
val predictionAndLabels = sc.parallelize(
2828
Seq(

‎mllib/src/test/scala/org/apache/spark/mllib/evaluation/RegressionMetricsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ package org.apache.spark.mllib.evaluation
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323
import org.apache.spark.mllib.util.TestingUtils._
2424

25-
class RegressionMetricsSuite extends FunSuite with LocalSparkContext {
25+
class RegressionMetricsSuite extends FunSuite with MLlibTestSparkContext {
2626

2727
test("regression metrics") {
2828
val predictionAndObservations = sc.parallelize(

‎mllib/src/test/scala/org/apache/spark/mllib/feature/HashingTFSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,9 @@ package org.apache.spark.mllib.feature
2020
import org.scalatest.FunSuite
2121

2222
import org.apache.spark.mllib.linalg.Vectors
23-
import org.apache.spark.mllib.util.LocalSparkContext
23+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2424

25-
class HashingTFSuite extends FunSuite with LocalSparkContext {
25+
class HashingTFSuite extends FunSuite with MLlibTestSparkContext {
2626

2727
test("hashing tf on a single doc") {
2828
val hashingTF = new HashingTF(1000)

‎mllib/src/test/scala/org/apache/spark/mllib/feature/IDFSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,10 @@ import org.scalatest.FunSuite
2121

2222
import org.apache.spark.SparkContext._
2323
import org.apache.spark.mllib.linalg.{DenseVector, SparseVector, Vectors}
24-
import org.apache.spark.mllib.util.LocalSparkContext
24+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2525
import org.apache.spark.mllib.util.TestingUtils._
2626

27-
class IDFSuite extends FunSuite with LocalSparkContext {
27+
class IDFSuite extends FunSuite with MLlibTestSparkContext {
2828

2929
test("idf") {
3030
val n = 4

‎mllib/src/test/scala/org/apache/spark/mllib/feature/NormalizerSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@ import org.scalatest.FunSuite
2222
import breeze.linalg.{norm => brzNorm}
2323

2424
import org.apache.spark.mllib.linalg.{DenseVector, SparseVector, Vectors}
25-
import org.apache.spark.mllib.util.LocalSparkContext
25+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2626
import org.apache.spark.mllib.util.TestingUtils._
2727

28-
class NormalizerSuite extends FunSuite with LocalSparkContext {
28+
class NormalizerSuite extends FunSuite with MLlibTestSparkContext {
2929

3030
val data = Array(
3131
Vectors.sparse(3, Seq((0, -2.0), (1, 2.3))),

‎mllib/src/test/scala/org/apache/spark/mllib/feature/StandardScalerSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,13 +20,13 @@ package org.apache.spark.mllib.feature
2020
import org.scalatest.FunSuite
2121

2222
import org.apache.spark.mllib.linalg.{DenseVector, SparseVector, Vector, Vectors}
23-
import org.apache.spark.mllib.util.LocalSparkContext
23+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2424
import org.apache.spark.mllib.util.TestingUtils._
2525
import org.apache.spark.mllib.rdd.RDDFunctions._
2626
import org.apache.spark.mllib.stat.{MultivariateStatisticalSummary, MultivariateOnlineSummarizer}
2727
import org.apache.spark.rdd.RDD
2828

29-
class StandardScalerSuite extends FunSuite with LocalSparkContext {
29+
class StandardScalerSuite extends FunSuite with MLlibTestSparkContext {
3030

3131
private def computeSummary(data: RDD[Vector]): MultivariateStatisticalSummary = {
3232
data.treeAggregate(new MultivariateOnlineSummarizer)(

‎mllib/src/test/scala/org/apache/spark/mllib/feature/Word2VecSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@ package org.apache.spark.mllib.feature
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323

24-
class Word2VecSuite extends FunSuite with LocalSparkContext {
24+
class Word2VecSuite extends FunSuite with MLlibTestSparkContext {
2525

2626
// TODO: add more tests
2727

‎mllib/src/test/scala/org/apache/spark/mllib/linalg/distributed/CoordinateMatrixSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,10 @@ import org.scalatest.FunSuite
2121

2222
import breeze.linalg.{DenseMatrix => BDM}
2323

24-
import org.apache.spark.mllib.util.LocalSparkContext
24+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2525
import org.apache.spark.mllib.linalg.Vectors
2626

27-
class CoordinateMatrixSuite extends FunSuite with LocalSparkContext {
27+
class CoordinateMatrixSuite extends FunSuite with MLlibTestSparkContext {
2828

2929
val m = 5
3030
val n = 4

‎mllib/src/test/scala/org/apache/spark/mllib/linalg/distributed/IndexedRowMatrixSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,11 @@ import org.scalatest.FunSuite
2121

2222
import breeze.linalg.{diag => brzDiag, DenseMatrix => BDM, DenseVector => BDV}
2323

24-
import org.apache.spark.mllib.util.LocalSparkContext
24+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2525
import org.apache.spark.rdd.RDD
2626
import org.apache.spark.mllib.linalg.{Matrices, Vectors}
2727

28-
class IndexedRowMatrixSuite extends FunSuite with LocalSparkContext {
28+
class IndexedRowMatrixSuite extends FunSuite with MLlibTestSparkContext {
2929

3030
val m = 4
3131
val n = 3

‎mllib/src/test/scala/org/apache/spark/mllib/linalg/distributed/RowMatrixSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@ import breeze.linalg.{DenseVector => BDV, DenseMatrix => BDM, norm => brzNorm, s
2323
import org.scalatest.FunSuite
2424

2525
import org.apache.spark.mllib.linalg.{Matrices, Vectors, Vector}
26-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
26+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2727

28-
class RowMatrixSuite extends FunSuite with LocalSparkContext {
28+
class RowMatrixSuite extends FunSuite with MLlibTestSparkContext {
2929

3030
val m = 4
3131
val n = 3

‎mllib/src/test/scala/org/apache/spark/mllib/optimization/GradientDescentSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import org.scalatest.{FunSuite, Matchers}
2424

2525
import org.apache.spark.mllib.linalg.Vectors
2626
import org.apache.spark.mllib.regression._
27-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
27+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2828
import org.apache.spark.mllib.util.TestingUtils._
2929

3030
object GradientDescentSuite {
@@ -61,7 +61,7 @@ object GradientDescentSuite {
6161
}
6262
}
6363

64-
class GradientDescentSuite extends FunSuite with LocalSparkContext with Matchers {
64+
class GradientDescentSuite extends FunSuite with MLlibTestSparkContext with Matchers {
6565

6666
test("Assert the loss is decreasing.") {
6767
val nPoints = 10000

‎mllib/src/test/scala/org/apache/spark/mllib/optimization/LBFGSSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import org.scalatest.{FunSuite, Matchers}
2323

2424
import org.apache.spark.mllib.linalg.Vectors
2525
import org.apache.spark.mllib.regression.LabeledPoint
26-
import org.apache.spark.mllib.util.{LocalClusterSparkContext, LocalSparkContext}
26+
import org.apache.spark.mllib.util.{LocalClusterSparkContext, MLlibTestSparkContext}
2727
import org.apache.spark.mllib.util.TestingUtils._
2828

29-
class LBFGSSuite extends FunSuite with LocalSparkContext with Matchers {
29+
class LBFGSSuite extends FunSuite with MLlibTestSparkContext with Matchers {
3030

3131
val nPoints = 10000
3232
val A = 2.0

‎mllib/src/test/scala/org/apache/spark/mllib/random/RandomRDDsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import org.scalatest.FunSuite
2424
import org.apache.spark.SparkContext._
2525
import org.apache.spark.mllib.linalg.Vector
2626
import org.apache.spark.mllib.rdd.{RandomRDDPartition, RandomRDD}
27-
import org.apache.spark.mllib.util.LocalSparkContext
27+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2828
import org.apache.spark.rdd.RDD
2929
import org.apache.spark.util.StatCounter
3030

@@ -34,7 +34,7 @@ import org.apache.spark.util.StatCounter
3434
*
3535
* TODO update tests to use TestingUtils for floating point comparison after PR 1367 is merged
3636
*/
37-
class RandomRDDsSuite extends FunSuite with LocalSparkContext with Serializable {
37+
class RandomRDDsSuite extends FunSuite with MLlibTestSparkContext with Serializable {
3838

3939
def testGeneratedRDD(rdd: RDD[Double],
4040
expectedSize: Long,

‎mllib/src/test/scala/org/apache/spark/mllib/rdd/RDDFunctionsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ package org.apache.spark.mllib.rdd
1919

2020
import org.scalatest.FunSuite
2121

22-
import org.apache.spark.mllib.util.LocalSparkContext
22+
import org.apache.spark.mllib.util.MLlibTestSparkContext
2323
import org.apache.spark.mllib.rdd.RDDFunctions._
2424

25-
class RDDFunctionsSuite extends FunSuite with LocalSparkContext {
25+
class RDDFunctionsSuite extends FunSuite with MLlibTestSparkContext {
2626

2727
test("sliding") {
2828
val data = 0 until 6

0 commit comments

Comments
 (0)