update style

Author: carsonwang

core/src/main/scala/org/apache/spark/ui/sql/SQLMetrics.scala

@@ -17,8 +17,8 @@
 
 package org.apache.spark.ui.sql
 
-import org.apache.spark.{SparkContext, AccumulableParam, Accumulable}
 import org.apache.spark.util.Utils
+import org.apache.spark.{Accumulable, AccumulableParam, SparkContext}
 
 /**
  * Create a layer for specialized metric. We cannot add `@specialized` to
@@ -144,6 +144,9 @@ private[spark] object SQLMetrics {
    * spill size, etc.
    */
   def createSizeMetric(sc: SparkContext, name: String): LongSQLMetric = {
+    // The final result of this metric in physical operator UI may looks like:
+    // data size total (min, med, max):
+    // 100GB (100MB, 1GB, 10GB)
     createLongMetric(sc, s"$name total (min, med, max)", StaticsLongSQLMetricParam)
   }
 

core/src/main/scala/org/apache/spark/ui/sql/SparkPlanGraph.scala

@@ -19,8 +19,6 @@ package org.apache.spark.ui.sql
 
 import java.util.concurrent.atomic.AtomicLong
 
-import org.apache.spark.util.Utils
-
 import scala.collection.mutable
 
 /**

sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala

@@ -21,8 +21,6 @@ import java.beans.{BeanInfo, Introspector}
 import java.util.Properties
 import java.util.concurrent.atomic.AtomicReference
 
-import org.apache.spark.ui.sql.{SQLTab, SQLListener}
-
 import scala.collection.JavaConverters._
 import scala.collection.immutable
 import scala.reflect.runtime.universe.TypeTag
@@ -48,6 +46,7 @@ import org.apache.spark.sql.sources.BaseRelation
 import org.apache.spark.sql.types._
 import org.apache.spark.sql.{execution => sparkexecution}
 import org.apache.spark.sql.util.ExecutionListenerManager
+import org.apache.spark.ui.sql.{SQLTab, SQLListener}
 import org.apache.spark.util.Utils
 
 /**

sql/core/src/main/scala/org/apache/spark/sql/execution/Aggregate.scala

@@ -18,6 +18,7 @@
 package org.apache.spark.sql.execution
 
 import java.util.HashMap
+
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.errors._

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala

@@ -19,8 +19,6 @@ package org.apache.spark.sql.execution
 
 import java.util.concurrent.atomic.AtomicBoolean
 
-import org.apache.spark.ui.sql.{LongSQLMetric, SQLMetric}
-
 import scala.collection.mutable.ArrayBuffer
 
 import org.apache.spark.Logging
@@ -34,6 +32,7 @@ import org.apache.spark.sql.catalyst.expressions.codegen._
 import org.apache.spark.sql.catalyst.plans.QueryPlan
 import org.apache.spark.sql.catalyst.plans.physical._
 import org.apache.spark.sql.types.DataType
+import org.apache.spark.ui.sql.{LongSQLMetric, SQLMetric}
 
 object SparkPlan {
   protected[sql] val currentContext = new ThreadLocal[SQLContext]()

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregationIterator.scala

@@ -17,8 +17,6 @@
 
 package org.apache.spark.sql.execution.aggregate
 
-import org.apache.spark.ui.sql.LongSQLMetric
-
 import scala.collection.mutable.ArrayBuffer
 
 import org.apache.spark.unsafe.KVIterator
@@ -29,6 +27,7 @@ import org.apache.spark.sql.catalyst.expressions.codegen.GenerateUnsafeRowJoiner
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.execution.{UnsafeKVExternalSorter, UnsafeFixedWidthAggregationMap}
 import org.apache.spark.sql.types.StructType
+import org.apache.spark.ui.sql.LongSQLMetric
 
 /**
  * An iterator used to evaluate aggregate functions. It operates on [[UnsafeRow]]s.

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala

@@ -17,8 +17,6 @@
 
 package org.apache.spark.sql.execution.joins
 
-import org.apache.spark.ui.sql.SQLMetrics
-
 import scala.concurrent._
 import scala.concurrent.duration._
 
@@ -27,6 +25,7 @@ import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.expressions.Expression
 import org.apache.spark.sql.catalyst.plans.physical.{Distribution, Partitioning, UnspecifiedDistribution}
 import org.apache.spark.sql.execution.{BinaryNode, SQLExecution, SparkPlan}
+import org.apache.spark.ui.sql.SQLMetrics
 import org.apache.spark.util.ThreadUtils
 import org.apache.spark.{InternalAccumulator, TaskContext}
 

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashOuterJoin.scala

@@ -17,8 +17,6 @@
 
 package org.apache.spark.sql.execution.joins
 
-import org.apache.spark.ui.sql.SQLMetrics
-
 import scala.concurrent._
 import scala.concurrent.duration._
 
@@ -28,6 +26,7 @@ import org.apache.spark.sql.catalyst.expressions._
 import org.apache.spark.sql.catalyst.plans.physical.{Distribution, Partitioning, UnspecifiedDistribution}
 import org.apache.spark.sql.catalyst.plans.{JoinType, LeftOuter, RightOuter}
 import org.apache.spark.sql.execution.{BinaryNode, SQLExecution, SparkPlan}
+import org.apache.spark.ui.sql.SQLMetrics
 import org.apache.spark.{InternalAccumulator, TaskContext}
 
 /**

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastLeftSemiJoinHash.scala

@@ -17,12 +17,12 @@
 
 package org.apache.spark.sql.execution.joins
 
-import org.apache.spark.ui.sql.SQLMetrics
 import org.apache.spark.{InternalAccumulator, TaskContext}
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.expressions._
 import org.apache.spark.sql.execution.{BinaryNode, SparkPlan}
+import org.apache.spark.ui.sql.SQLMetrics
 
 /**
  * Build the right table's join keys into a HashSet, and iteratively go through the left

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/ShuffledHashOuterJoin.scala

@@ -17,8 +17,6 @@
 
 package org.apache.spark.sql.execution.joins
 
-import org.apache.spark.ui.sql.SQLMetrics
-
 import scala.collection.JavaConverters._
 
 import org.apache.spark.rdd.RDD
@@ -27,6 +25,7 @@ import org.apache.spark.sql.catalyst.expressions._
 import org.apache.spark.sql.catalyst.plans.physical._
 import org.apache.spark.sql.catalyst.plans.{FullOuter, JoinType, LeftOuter, RightOuter}
 import org.apache.spark.sql.execution.{BinaryNode, SparkPlan}
+import org.apache.spark.ui.sql.SQLMetrics
 
 /**
  * Performs a hash based outer join for two child relations by shuffling the data using