Home
last modified time | relevance | path

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

/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/
H A DTaskInfo.scala50 var gettingResultTime: Long = 0 variable
70 gettingResultTime = time
82 def gettingResult: Boolean = gettingResultTime != 0
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ui/jobs/
H A DStagePage.scala631 val gettingResultTime = getGettingResultTime(taskUIData.taskInfo, currentTime) constant
632 val gettingResultTimeProportion = toProportion(gettingResultTime)
639 totalExecutionTime - executorOverhead - gettingResultTime
642 totalExecutionTime - executorOverhead - gettingResultTime)
775 info.finishTime - info.gettingResultTime
778 currentTime - info.gettingResultTime
845 val gettingResultTime: Long, constant
898 val gettingResultTime = getGettingResultTime(info, currentTime) constant
1029 gettingResultTime,
1058 case "Getting Result Time" => Ordering.by(_.gettingResultTime)
[all …]
H A DUIData.scala173 newTaskInfo.gettingResultTime = taskInfo.gettingResultTime
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/
H A DJsonProtocol.scala279 ("Getting Result Time" -> taskInfo.gettingResultTime) ~
708 val gettingResultTime = (json \ "Getting Result Time").extract[Long] constant
719 taskInfo.gettingResultTime = gettingResultTime
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/util/
H A DJsonProtocolSuite.scala596 assert(info1.gettingResultTime === info2.gettingResultTime)