From 00e9cc5c110d29478eb12037a3d3e643f94b5849 Mon Sep 17 00:00:00 2001
From: Imran Rashid <irashid@cloudera.com>
Date: Mon, 16 Mar 2015 11:45:36 -0500
Subject: [PATCH] more style

---
 .../scala/org/apache/spark/status/api/v1/AllRDDResource.scala | 2 +-
 .../org/apache/spark/status/api/v1/AllStagesResource.scala    | 4 ++--
 .../org/apache/spark/status/api/v1/OneStageResource.scala     | 2 +-
 .../org/apache/spark/deploy/history/HistoryServerSuite.scala  | 4 ++--
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/AllRDDResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/AllRDDResource.scala
index 1c540288c40f9..b3f9732aac599 100644
--- a/core/src/main/scala/org/apache/spark/status/api/v1/AllRDDResource.scala
+++ b/core/src/main/scala/org/apache/spark/status/api/v1/AllRDDResource.scala
@@ -83,7 +83,7 @@ object AllRDDResource {
       None
     }
     val partitions = if (includeDetails) {
-      Some(blocks.map { case(id, block, locations) =>
+      Some(blocks.map { case (id, block, locations) =>
         new RDDPartitionInfo(
           blockName = id.name,
           storageLevel = block.storageLevel.description,
diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala
index 516d76edb9609..2794345763506 100644
--- a/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala
+++ b/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala
@@ -66,12 +66,12 @@ object AllStagesResource {
   ): StageData = {
 
     val taskData = if(includeDetails) {
-      Some(stageUiData.taskData.map { case(k,v) => k -> convertTaskData(v) } )
+      Some(stageUiData.taskData.map { case (k, v) => k -> convertTaskData(v) } )
     } else {
       None
     }
     val executorSummary = if(includeDetails) {
-      Some(stageUiData.executorSummary.map { case(k,summary) =>
+      Some(stageUiData.executorSummary.map { case (k, summary) =>
         k -> new ExecutorStageSummary(
           taskTime = summary.taskTime,
           failedTasks = summary.failedTasks,
diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala
index 4b756ac93f01e..df7a5aec8f7ac 100644
--- a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala
+++ b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala
@@ -37,7 +37,7 @@ class OneStageResource(uiRoot: UIRoot) {
         matched.map { status -> _ }
       }.headOption
       oneStage match {
-        case Some((status,stageInfo)) =>
+        case Some((status, stageInfo)) =>
           val stageUiData = listener.synchronized {
             listener.stageIdToData.get((stageInfo.stageId, stageInfo.attemptId)).
               getOrElse(throw new SparkException("failed to get full stage data for stage: " +
diff --git a/core/src/test/scala/org/apache/spark/deploy/history/HistoryServerSuite.scala b/core/src/test/scala/org/apache/spark/deploy/history/HistoryServerSuite.scala
index 4b81942421fc8..016343af1e431 100644
--- a/core/src/test/scala/org/apache/spark/deploy/history/HistoryServerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/history/HistoryServerSuite.scala
@@ -82,8 +82,8 @@ class HistoryServerSuite extends FunSuite with BeforeAndAfter with Matchers with
 
   //run a bunch of characterization tests -- just verify the behavior is the same as what is saved in the test
   // resource folder
-  cases.foreach{case(name, path) =>
-      test(name){
+  cases.foreach { case (name, path) =>
+      test(name) {
         val (code, jsonOpt, errOpt) = getContentAndCode(path)
         code should be (HttpServletResponse.SC_OK)
         jsonOpt should be ('defined)