From b4a7863dad5152cf989faab338b121600b889eb3 Mon Sep 17 00:00:00 2001 From: Imran Rashid Date: Wed, 1 Apr 2015 16:17:42 -0500 Subject: [PATCH] fix compile error --- .../org/apache/spark/status/api/v1/AllStagesResource.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 10a589d49c5de..66cad59d00f37 100644 --- 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 @@ -153,7 +153,7 @@ private[v1] object AllStagesResource { def getMetric[T](data: Seq[T], f: T => Double): IndexedSeq[Double] = Distribution(data.map{d=> f(d)}).get.getQuantiles(quantiles) - private abstract class MetricHelper[I,O](f: InternalTaskMetrics => Option[I]) { + abstract class MetricHelper[I,O](f: InternalTaskMetrics => Option[I]) { val data: Seq[I] = rawMetrics.flatMap{x => f(x)} def build: O def m(f: I => Double): IndexedSeq[Double] = getMetric(data, f)