From 5656dcdfe581cdc9da8d3abb2bab16ef265758cc Mon Sep 17 00:00:00 2001 From: Denny <dennybritz@gmail.com> Date: Mon, 23 Jul 2012 10:36:30 -0700 Subject: [PATCH] Stlystic changes --- bagel/src/test/scala/bagel/BagelSuite.scala | 4 ++-- core/src/main/scala/spark/broadcast/Broadcast.scala | 2 +- core/src/test/scala/spark/BroadcastSuite.scala | 4 ++-- core/src/test/scala/spark/FailureSuite.scala | 4 ++-- core/src/test/scala/spark/FileSuite.scala | 6 +++--- core/src/test/scala/spark/MesosSchedulerSuite.scala | 2 +- core/src/test/scala/spark/PartitioningSuite.scala | 4 ++-- core/src/test/scala/spark/PipedRDDSuite.scala | 4 ++-- core/src/test/scala/spark/RDDSuite.scala | 6 +++--- core/src/test/scala/spark/ShuffleSuite.scala | 4 ++-- core/src/test/scala/spark/SortingSuite.scala | 4 ++-- core/src/test/scala/spark/ThreadingSuite.scala | 4 ++-- 12 files changed, 24 insertions(+), 24 deletions(-) diff --git a/bagel/src/test/scala/bagel/BagelSuite.scala b/bagel/src/test/scala/bagel/BagelSuite.scala index 5ac7f5d381..d2189169d2 100644 --- a/bagel/src/test/scala/bagel/BagelSuite.scala +++ b/bagel/src/test/scala/bagel/BagelSuite.scala @@ -13,11 +13,11 @@ import spark._ class TestVertex(val active: Boolean, val age: Int) extends Vertex with Serializable class TestMessage(val targetId: String) extends Message[String] with Serializable -class BagelSuite extends FunSuite with Assertions with BeforeAndAfter{ +class BagelSuite extends FunSuite with Assertions with BeforeAndAfter { var sc: SparkContext = _ - after{ + after { sc.stop() } diff --git a/core/src/main/scala/spark/broadcast/Broadcast.scala b/core/src/main/scala/spark/broadcast/Broadcast.scala index 06049749a9..07094a034e 100644 --- a/core/src/main/scala/spark/broadcast/Broadcast.scala +++ b/core/src/main/scala/spark/broadcast/Broadcast.scala @@ -175,7 +175,7 @@ object Broadcast extends Logging with Serializable { } private def byteArrayToObject[OUT](bytes: Array[Byte]): OUT = { - val in = new ObjectInputStream (new ByteArrayInputStream (bytes)){ + val in = new ObjectInputStream (new ByteArrayInputStream (bytes)) { override def resolveClass(desc: ObjectStreamClass) = Class.forName(desc.getName, false, Thread.currentThread.getContextClassLoader) } diff --git a/core/src/test/scala/spark/BroadcastSuite.scala b/core/src/test/scala/spark/BroadcastSuite.scala index d22c2d4295..1e0b587421 100644 --- a/core/src/test/scala/spark/BroadcastSuite.scala +++ b/core/src/test/scala/spark/BroadcastSuite.scala @@ -7,8 +7,8 @@ class BroadcastSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/FailureSuite.scala b/core/src/test/scala/spark/FailureSuite.scala index 6226283361..6145baee7b 100644 --- a/core/src/test/scala/spark/FailureSuite.scala +++ b/core/src/test/scala/spark/FailureSuite.scala @@ -25,8 +25,8 @@ class FailureSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/FileSuite.scala b/core/src/test/scala/spark/FileSuite.scala index 3a77ed0f13..4cb9c7802f 100644 --- a/core/src/test/scala/spark/FileSuite.scala +++ b/core/src/test/scala/spark/FileSuite.scala @@ -11,12 +11,12 @@ import org.apache.hadoop.io._ import SparkContext._ -class FileSuite extends FunSuite with BeforeAndAfter{ +class FileSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/MesosSchedulerSuite.scala b/core/src/test/scala/spark/MesosSchedulerSuite.scala index 0e6820cbdc..2f1bea58b5 100644 --- a/core/src/test/scala/spark/MesosSchedulerSuite.scala +++ b/core/src/test/scala/spark/MesosSchedulerSuite.scala @@ -3,7 +3,7 @@ package spark import org.scalatest.FunSuite class MesosSchedulerSuite extends FunSuite { - test("memoryStringToMb"){ + test("memoryStringToMb") { assert(MesosScheduler.memoryStringToMb("1") == 0) assert(MesosScheduler.memoryStringToMb("1048575") == 0) diff --git a/core/src/test/scala/spark/PartitioningSuite.scala b/core/src/test/scala/spark/PartitioningSuite.scala index dfe6a295c8..cf2ffeb9b1 100644 --- a/core/src/test/scala/spark/PartitioningSuite.scala +++ b/core/src/test/scala/spark/PartitioningSuite.scala @@ -11,8 +11,8 @@ class PartitioningSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/PipedRDDSuite.scala b/core/src/test/scala/spark/PipedRDDSuite.scala index c0cf034c72..db1b9835a0 100644 --- a/core/src/test/scala/spark/PipedRDDSuite.scala +++ b/core/src/test/scala/spark/PipedRDDSuite.scala @@ -8,8 +8,8 @@ class PipedRDDSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala index 1d240b471f..3924a6890b 100644 --- a/core/src/test/scala/spark/RDDSuite.scala +++ b/core/src/test/scala/spark/RDDSuite.scala @@ -5,12 +5,12 @@ import org.scalatest.FunSuite import org.scalatest.BeforeAndAfter import SparkContext._ -class RDDSuite extends FunSuite with BeforeAndAfter{ +class RDDSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/ShuffleSuite.scala b/core/src/test/scala/spark/ShuffleSuite.scala index aca286f3ad..3ba0e274b7 100644 --- a/core/src/test/scala/spark/ShuffleSuite.scala +++ b/core/src/test/scala/spark/ShuffleSuite.scala @@ -17,8 +17,8 @@ class ShuffleSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/SortingSuite.scala b/core/src/test/scala/spark/SortingSuite.scala index ced3c66d38..d2dd514edb 100644 --- a/core/src/test/scala/spark/SortingSuite.scala +++ b/core/src/test/scala/spark/SortingSuite.scala @@ -8,8 +8,8 @@ class SortingSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } diff --git a/core/src/test/scala/spark/ThreadingSuite.scala b/core/src/test/scala/spark/ThreadingSuite.scala index 6126883a21..a8b5ccf721 100644 --- a/core/src/test/scala/spark/ThreadingSuite.scala +++ b/core/src/test/scala/spark/ThreadingSuite.scala @@ -26,8 +26,8 @@ class ThreadingSuite extends FunSuite with BeforeAndAfter { var sc: SparkContext = _ - after{ - if(sc != null){ + after { + if(sc != null) { sc.stop() } } -- GitLab