Move diskBytesSpilled getter next to variable

nemccarthy · May 25, 2015 · 8d0678c · 8d0678c
1 parent 19bccd6
commit 8d0678c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala
@@ -147,6 +147,7 @@ private[spark] class ExternalSorter[K, V, C](
 
   // Total spilling statistics
   private var _diskBytesSpilled = 0L
+  def diskBytesSpilled: Long = _diskBytesSpilled
 
   // Write metrics for current spill
   private var curWriteMetrics: ShuffleWriteMetrics = _
@@ -818,8 +819,6 @@ private[spark] class ExternalSorter[K, V, C](
     }
   }
 
-  def diskBytesSpilled: Long = _diskBytesSpilled
-
   /**
    * Given a stream of ((partition, key), combiner) pairs *assumed to be sorted by partition ID*,
    * group together the pairs for each partition into a sub-iterator.