style

nemccarthy · Apr 1, 2015 · 1f53a66 · 1f53a66
1 parent b4a7863
commit 1f53a66
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
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
@@ -146,7 +146,9 @@ private[v1] object AllStagesResource {
     )
   }
 
-  def taskMetricDistributions(allTaskData: Iterable[TaskUIData], quantiles: Array[Double]): TaskMetricDistributions = {
+  def taskMetricDistributions(
+      allTaskData: Iterable[TaskUIData],
+      quantiles: Array[Double]): TaskMetricDistributions = {
 
     val rawMetrics = allTaskData.flatMap{_.taskMetrics}.toSeq
 
@@ -186,7 +188,8 @@ private[v1] object AllStagesResource {
       }.metricOption
 
     val shuffleReadMetrics =
-      new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](_.shuffleReadMetrics) {
+      new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](
+          _.shuffleReadMetrics) {
         def build: ShuffleReadMetricDistributions = new ShuffleReadMetricDistributions(
           readBytes = m(_.totalBytesRead),
           readRecords = m(_.recordsRead),
@@ -199,7 +202,8 @@ private[v1] object AllStagesResource {
       }.metricOption
 
     val shuffleWriteMetrics =
-      new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](_.shuffleWriteMetrics) {
+      new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](
+          _.shuffleWriteMetrics) {
         def build: ShuffleWriteMetricDistributions = new ShuffleWriteMetricDistributions(
           writeBytes = m(_.shuffleBytesWritten),
           writeRecords = m(_.shuffleRecordsWritten),

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
@@ -178,7 +178,8 @@ object TaskSorting extends JerseyEnum[TaskSorting] {
     DecreasingRuntime
   )
 
-  val alternateNames: Map[String, TaskSorting] = values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap
+  val alternateNames: Map[String, TaskSorting] =
+    values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap
 
   override def fromString(s: String): TaskSorting = {
     alternateNames.find { case (k, v) =>