diff options
author | Sandy Ryza <sandy@cloudera.com> | 2014-12-09 16:26:07 -0800 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2014-12-09 16:26:07 -0800 |
commit | 5e4c06f8e54265a4024857f5978ec54c936aeea2 (patch) | |
tree | d8972737fe97fad96188bae1d489b442466a6812 | |
parent | 30dca924df0efbdc1b638fa7c705fe8743570783 (diff) | |
download | spark-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
-rw-r--r-- | core/src/main/java/org/apache/spark/SparkJobInfo.java | 4 | ||||
-rw-r--r-- | core/src/main/java/org/apache/spark/SparkStageInfo.java | 4 |
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(); |