diff options
Diffstat (limited to 'core/src/main/scala/spark/HadoopRDD.scala')
| -rw-r--r-- | core/src/main/scala/spark/HadoopRDD.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/HadoopRDD.scala b/core/src/main/scala/spark/HadoopRDD.scala index c87fa844c3..47286e0a65 100644 --- a/core/src/main/scala/spark/HadoopRDD.scala +++ b/core/src/main/scala/spark/HadoopRDD.scala @@ -13,8 +13,8 @@ import org.apache.hadoop.mapred.Reporter import org.apache.hadoop.util.ReflectionUtils /** A Spark split class that wraps around a Hadoop InputSplit */ -@serializable class HadoopSplit(rddId: Int, idx: Int, @transient s: InputSplit) -extends Split { +class HadoopSplit(rddId: Int, idx: Int, @transient s: InputSplit) +extends Split with Serializable { val inputSplit = new SerializableWritable[InputSplit](s) override def hashCode(): Int = (41 * (41 + rddId) + idx).toInt |