Skip to content
This repository was archived by the owner on Dec 15, 2025. It is now read-only.

Commit 2bfa491

Browse files
author
Peng Meng
committed
ALS prepare data to support scala 2.10
1 parent f1b3aba commit 2bfa491

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

sparkbench/ml/src/main/scala/com/intel/sparkbench/ml/RatingDataGenerator.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,6 @@ import org.apache.spark.mllib.random._
2727
import org.apache.spark.rdd.{PairRDDFunctions, RDD}
2828
import org.apache.spark.mllib.linalg.{Vectors, Vector}
2929

30-
import scala.util.Random
31-
3230
object RatingDataGenerator {
3331

3432
def main(args: Array[String]): Unit = {
@@ -63,7 +61,7 @@ object RatingDataGenerator {
6361
}
6462

6563
val rawData: RDD[Vector] = RandomRDDs.normalVectorRDD(sc, numUsers, numProducts, numPartitions)
66-
val rng = new Random()
64+
val rng = new java.util.Random()
6765
val data = rawData.map{v =>
6866
val a = Array.fill[Double](v.size)(0.0)
6967
v.foreachActive{(i,vi) =>

0 commit comments

Comments
 (0)