fix compile error

nemccarthy · Apr 1, 2015 · b4a7863 · b4a7863
1 parent 2c8b7ee
commit b4a7863
Showing 1 changed file with 1 addition and 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
@@ -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)