We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2c8b7ee commit b4a7863Copy full SHA for b4a7863
core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala
@@ -153,7 +153,7 @@ private[v1] object AllStagesResource {
153
def getMetric[T](data: Seq[T], f: T => Double): IndexedSeq[Double] =
154
Distribution(data.map{d=> f(d)}).get.getQuantiles(quantiles)
155
156
- private abstract class MetricHelper[I,O](f: InternalTaskMetrics => Option[I]) {
+ abstract class MetricHelper[I,O](f: InternalTaskMetrics => Option[I]) {
157
val data: Seq[I] = rawMetrics.flatMap{x => f(x)}
158
def build: O
159
def m(f: I => Double): IndexedSeq[Double] = getMetric(data, f)
0 commit comments