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/scala/org/apache | |
| 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/scala/org/apache')
| -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, |