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:28 -0800 |
commit | 51da2c557b98aec8309db01ecf8dd0f39c494d28 (patch) | |
tree | a234fce98170109935e179703f4017f6f827f713 /core | |
parent | 5a3a3cc1739e4d5004bc7117bd6afadf3142ec9b (diff) | |
download | spark-51da2c557b98aec8309db01ecf8dd0f39c494d28.tar.gz spark-51da2c557b98aec8309db01ecf8dd0f39c494d28.tar.bz2 spark-51da2c557b98aec8309db01ecf8dd0f39c494d28.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
(cherry picked from commit 5e4c06f8e54265a4024857f5978ec54c936aeea2)
Signed-off-by: Josh Rosen <joshrosen@databricks.com>
Diffstat (limited to 'core')
-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(); |