From e95bf691a0427626965674e992bb43469fda3561 Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Fri, 1 Aug 2014 23:55:02 -0700 Subject: [PATCH] Stash --- .../src/main/scala/org/apache/spark/Accumulators.scala | 10 ---------- .../org/apache/spark/scheduler/DAGScheduler.scala | 4 ++-- 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/Accumulators.scala b/core/src/main/scala/org/apache/spark/Accumulators.scala index 4185d185699d1..845eaabf43703 100644 --- 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 index 846a313e8ae54..03a8c98c0a95a 100644 --- 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)