File tree Expand file tree Collapse file tree 2 files changed +2
-1
lines changed
core/src/main/scala/org/apache/spark/status/api/v1 Expand file tree Collapse file tree 2 files changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -72,3 +72,4 @@ local-1422981759269/*
7272local-1422981780767/*
7373local-1425081759269/*
7474local-1426533911241/*
75+ local-1427397477963/*
Original file line number Diff line number Diff line change @@ -153,7 +153,7 @@ private[v1] object AllStagesResource {
153153 def getMetric [T ](data : Seq [T ], f : T => Double ): IndexedSeq [Double ] =
154154 Distribution (data.map{d=> f(d)}).get.getQuantiles(quantiles)
155155
156- abstract class MetricHelper [I ,O ](f : InternalTaskMetrics => Option [I ]) {
156+ private abstract class MetricHelper [I ,O ](f : InternalTaskMetrics => Option [I ]) {
157157 val data : Seq [I ] = rawMetrics.flatMap{x => f(x)}
158158 def build : O
159159 def m (f : I => Double ): IndexedSeq [Double ] = getMetric(data, f)
You can’t perform that action at this time.
0 commit comments