diff options
Diffstat (limited to 'core/src/main/scala/spark/RDD.scala')
| -rw-r--r-- | core/src/main/scala/spark/RDD.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala index a0c4e29771..445d520bc2 100644 --- a/core/src/main/scala/spark/RDD.scala +++ b/core/src/main/scala/spark/RDD.scala @@ -44,8 +44,7 @@ import SparkContext._ * In addition, PairRDDFunctions contains extra methods available on RDDs of key-value pairs, * and SequenceFileRDDFunctions contains extra methods for saving RDDs to Hadoop SequenceFiles. */ -@serializable -abstract class RDD[T: ClassManifest](@transient sc: SparkContext) { +abstract class RDD[T: ClassManifest](@transient sc: SparkContext) extends Serializable { // Methods that must be implemented by subclasses def splits: Array[Split] def compute(split: Split): Iterator[T] |