aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorSandy Ryza <sandy@cloudera.com>2014-12-09 16:26:07 -0800
committerJosh Rosen <joshrosen@databricks.com>2014-12-09 16:26:07 -0800
commit5e4c06f8e54265a4024857f5978ec54c936aeea2 (patch)
treed8972737fe97fad96188bae1d489b442466a6812 /core
parent30dca924df0efbdc1b638fa7c705fe8743570783 (diff)
downloadspark-5e4c06f8e54265a4024857f5978ec54c936aeea2.tar.gz
spark-5e4c06f8e54265a4024857f5978ec54c936aeea2.tar.bz2
spark-5e4c06f8e54265a4024857f5978ec54c936aeea2.zip
SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable
Author: Sandy Ryza <sandy@cloudera.com> Closes #3426 from sryza/sandy-spark-4567 and squashes the following commits: cb4b8d2 [Sandy Ryza] SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable
Diffstat (limited to 'core')
-rw-r--r--core/src/main/java/org/apache/spark/SparkJobInfo.java4
-rw-r--r--core/src/main/java/org/apache/spark/SparkStageInfo.java4
2 files changed, 6 insertions, 2 deletions
diff --git a/core/src/main/java/org/apache/spark/SparkJobInfo.java b/core/src/main/java/org/apache/spark/SparkJobInfo.java
index 4e3c983b11..e31c440163 100644
--- a/core/src/main/java/org/apache/spark/SparkJobInfo.java
+++ b/core/src/main/java/org/apache/spark/SparkJobInfo.java
@@ -17,13 +17,15 @@
package org.apache.spark;
+import java.io.Serializable;
+
/**
* Exposes information about Spark Jobs.
*
* This interface is not designed to be implemented outside of Spark. We may add additional methods
* which may break binary compatibility with outside implementations.
*/
-public interface SparkJobInfo {
+public interface SparkJobInfo extends Serializable {
int jobId();
int[] stageIds();
JobExecutionStatus status();
diff --git a/core/src/main/java/org/apache/spark/SparkStageInfo.java b/core/src/main/java/org/apache/spark/SparkStageInfo.java
index fd74321093..b7d462abd7 100644
--- a/core/src/main/java/org/apache/spark/SparkStageInfo.java
+++ b/core/src/main/java/org/apache/spark/SparkStageInfo.java
@@ -17,13 +17,15 @@
package org.apache.spark;
+import java.io.Serializable;
+
/**
* Exposes information about Spark Stages.
*
* This interface is not designed to be implemented outside of Spark. We may add additional methods
* which may break binary compatibility with outside implementations.
*/
-public interface SparkStageInfo {
+public interface SparkStageInfo extends Serializable {
int stageId();
int currentAttemptId();
long submissionTime();