File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
core/src/main/scala/org/apache/spark/status/api/v1 Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -287,10 +287,7 @@ private[v1] object AllStagesResource {
287287 * Helper for getting distributions from nested metric types. Many of the metrics we want are
288288 * contained in options inside TaskMetrics (eg., ShuffleWriteMetrics). This makes it easy to handle
289289 * the options (returning None if the metrics are all empty), and extract the quantiles for each
290- * metric. After creating an instance, call metricOption to get the result type
291- *
292- * **getSubMetrics** -- pulls out the submetric of interest from the overall task metrics
293- * **build** -- create the result container. Generally this will just call submetricQuantiles for each
290+ * metric. After creating an instance, call metricOption to get the result type.
294291 */
295292private [v1] abstract class MetricHelper [I ,O ](
296293 rawMetrics : Seq [InternalTaskMetrics ],
@@ -299,7 +296,7 @@ private[v1] abstract class MetricHelper[I,O](
299296 def getSubmetrics (raw : InternalTaskMetrics ): Option [I ]
300297 def build : O
301298 val data : Seq [I ] = rawMetrics.flatMap(getSubmetrics)
302- /** applies the given function to all input metrics, and returns the quantiles*/
299+ /** applies the given function to all input metrics, and returns the quantiles */
303300 def submetricQuantiles (f : I => Double ): IndexedSeq [Double ] = {
304301 Distribution (data.map { d => f(d) }).get.getQuantiles(quantiles)
305302 }
You can’t perform that action at this time.
0 commit comments