diff options
author | Alex Bozarth <ajbozart@us.ibm.com> | 2016-04-01 16:18:09 -0700 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2016-04-01 16:18:09 -0700 |
commit | abc6c42c2d76d6aa4a8cac605cb4214e8f8f3328 (patch) | |
tree | 85e2433db2e8327d3345e3a1dcdd9ee082f9f2b8 /core/src/main | |
parent | 19f32f2d99c3620c0e562a98f7890316ddad1de9 (diff) | |
download | spark-abc6c42c2d76d6aa4a8cac605cb4214e8f8f3328.tar.gz spark-abc6c42c2d76d6aa4a8cac605cb4214e8f8f3328.tar.bz2 spark-abc6c42c2d76d6aa4a8cac605cb4214e8f8f3328.zip |
[SPARK-13241][WEB UI] Added long values for dates in ApplicationAttemptInfo API
## What changes were proposed in this pull request?
Adding long values for each Date in the ApplicationAttemptInfo API for easier use in code
## How was the this patch tested?
Tested with dev/run-tests
Author: Alex Bozarth <ajbozart@us.ibm.com>
Closes #11326 from ajbozarth/spark13241.
Diffstat (limited to 'core/src/main')
-rw-r--r-- | core/src/main/scala/org/apache/spark/status/api/v1/api.scala | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/api.scala b/core/src/main/scala/org/apache/spark/status/api/v1/api.scala index d43868bbcb..ebbbf48148 100644 --- a/core/src/main/scala/org/apache/spark/status/api/v1/api.scala +++ b/core/src/main/scala/org/apache/spark/status/api/v1/api.scala @@ -38,7 +38,11 @@ class ApplicationAttemptInfo private[spark]( val lastUpdated: Date, val duration: Long, val sparkUser: String, - val completed: Boolean = false) + val completed: Boolean = false) { + def getStartTimeEpoch: Long = startTime.getTime + def getEndTimeEpoch: Long = endTime.getTime + def getLastUpdatedEpoch: Long = lastUpdated.getTime +} class ExecutorStageSummary private[spark]( val taskTime : Long, |