Home
last modified time | relevance | path

Searched refs:peakExecutionMemory (Results 1 – 5 of 5) sorted by relevance

/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/ui/
H A DStagePageSuite.scala36 private val peakExecutionMemory = 10
49 assert(html.contains(s"<td>$peakExecutionMemory.0 b</td>" * 5))
82 taskMetrics.incPeakExecutionMemory(peakExecutionMemory)
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ui/jobs/
H A DUIData.scala149 peakExecutionMemory = m.peakExecutionMemory,
194 peakExecutionMemory: Long,
H A DStagePage.scala406 val peakExecutionMemory = validTasks.map { taskUIData: TaskUIData => constant
407 taskUIData.metrics.get.peakExecutionMemory.toDouble
415 </td> +: getFormattedSizeQuantiles(peakExecutionMemory)
908 val peakExecutionMemoryUsed = metrics.map(_.peakExecutionMemory).getOrElse(0L)
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/executor/
H A DTaskMetricsSuite.scala39 assert(tm.peakExecutionMemory == 0L)
70 assert(tm.peakExecutionMemory == 808L)
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/executor/
H A DTaskMetrics.scala111 def peakExecutionMemory: Long = _peakExecutionMemory.sum method