Stash

giwa · Aug 2, 2014 · e95bf69 · e95bf69
1 parent be97261
commit e95bf69
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 12 deletions.
diff --git a/core/src/main/scala/org/apache/spark/Accumulators.scala b/core/src/main/scala/org/apache/spark/Accumulators.scala
@@ -99,16 +99,6 @@ class Accumulable[R, T] (
     }
   }
 
-  /**
-   * Function to customize printing values of this accumulator.
-   */
-  def prettyValue(_value: R) = s"$value"
-
-  /**
-   * Function to customize printing partially accumulated (local) values of this accumulator.
-   */
-  def prettyPartialValue(_value: R) = prettyValue(_value)
-
   /**
    * Get the current value of this accumulator from within a task.
    *

diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -822,8 +822,8 @@ class DAGScheduler(
             val name = acc.name
             // To avoid UI cruft, ignore cases where value wasn't updated
             if (partialValue != acc.zero) {
-              val stringPartialValue = acc.prettyPartialValue(partialValue)
-              val stringValue = acc.prettyValue(acc.value)
+              val stringPartialValue = "%s".format(partialValue)
+              val stringValue = "%s".format(acc.value)
               stageToInfos(stage).accumulables(id) = AccumulableInfo(id, acc.name, stringValue)
               event.taskInfo.accumulables +=
                 AccumulableInfo(id, name, Some(stringPartialValue), stringValue)