aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/StatusAPIImpl.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/scala/org/apache/spark/StatusAPIImpl.scala')
-rw-r--r--core/src/main/scala/org/apache/spark/StatusAPIImpl.scala33
1 files changed, 20 insertions, 13 deletions
diff --git a/core/src/main/scala/org/apache/spark/StatusAPIImpl.scala b/core/src/main/scala/org/apache/spark/StatusAPIImpl.scala
index e5c7c8d0db..c1f24a6377 100644
--- a/core/src/main/scala/org/apache/spark/StatusAPIImpl.scala
+++ b/core/src/main/scala/org/apache/spark/StatusAPIImpl.scala
@@ -18,18 +18,25 @@
package org.apache.spark
private class SparkJobInfoImpl (
- val jobId: Int,
- val stageIds: Array[Int],
- val status: JobExecutionStatus)
- extends SparkJobInfo
+ val jobId: Int,
+ val stageIds: Array[Int],
+ val status: JobExecutionStatus)
+ extends SparkJobInfo
private class SparkStageInfoImpl(
- val stageId: Int,
- val currentAttemptId: Int,
- val submissionTime: Long,
- val name: String,
- val numTasks: Int,
- val numActiveTasks: Int,
- val numCompletedTasks: Int,
- val numFailedTasks: Int)
- extends SparkStageInfo
+ val stageId: Int,
+ val currentAttemptId: Int,
+ val submissionTime: Long,
+ val name: String,
+ val numTasks: Int,
+ val numActiveTasks: Int,
+ val numCompletedTasks: Int,
+ val numFailedTasks: Int)
+ extends SparkStageInfo
+
+private class SparkExecutorInfoImpl(
+ val host: String,
+ val port: Int,
+ val cacheSize: Long,
+ val numRunningTasks: Int)
+ extends SparkExecutorInfo