Merge pull request #230 from renaissance-benchmarks/ff/check-style-fix

Checkstyle fix
renaissance-benchmarks · Apr 14, 2020 · 393adff · 393adff
2 parents 6013341 + 10dc098
commit 393adff
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/LogRegression.scala b/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/LogRegression.scala
@@ -96,7 +96,8 @@ final class LogRegression extends Benchmark with SparkUtil {
  features(index) = value
  }
  (parts(0).toDouble, Vectors.dense(features))
- }.cache()
+ }
+ .cache()
  }
 
  override def setUpBeforeAll(c: BenchmarkContext): Unit = {

diff --git a/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/MovieLens.scala b/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/MovieLens.scala
@@ -146,7 +146,8 @@ final class MovieLens extends Benchmark with SparkUtil {
  val fields = line.split(",")
  // Format: (timestamp % 10, Rating(userId, movieId, rating))
  (fields(3).toLong % 10, Rating(fields(0).toInt, fields(1).toInt, fields(2).toDouble))
- }.cache()
+ }
+ .cache()
 
  numRatings = ratings.count()
  numUsers = ratings.map(_._2.user).distinct().count()
@@ -171,18 +172,21 @@ final class MovieLens extends Benchmark with SparkUtil {
  .filter(x => x._1 < trainingThreshold)
  .values
  .union(personalRatingsRDD)
- .repartition(numPartitions).cache()
+ .repartition(numPartitions)
+ .cache()
  numTraining = training.count()
 
  validation = ratings
  .filter(x => x._1 >= trainingThreshold && x._1 < validationThreshold)
  .values
- .repartition(numPartitions).cache()
+ .repartition(numPartitions)
+ .cache()
  numValidation = validation.count()
 
  test = ratings
  .filter(x => x._1 >= validationThreshold)
- .values.cache()
+ .values
+ .cache()
  numTest = test.count()
 
  println(

diff --git a/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/SparkUtil.scala b/benchmarks/apache-spark/src/main/scala/org/renaissance/apache/spark/SparkUtil.scala
@@ -10,7 +10,6 @@ import org.apache.spark.SparkConf
 import org.apache.spark.SparkContext
 import org.apache.spark.rdd.RDD
 
-
 trait SparkUtil {
 
  val portAllocationMaxRetries: Int = 16