diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-24 23:52:32 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-24 23:52:32 -0700 |
| commit | 4d3339a3ecec2a910fc6a963e825bd7fb97919c5 (patch) | |
| tree | 4300aa932779a4fbf40dd287bc3baf27582ba606 /core | |
| parent | 296e24b440d33895d0eae1d5e6d8b35a95469eb2 (diff) | |
| parent | 7a4cd9286172d4a16d2911649a5bf9ea216ca980 (diff) | |
| download | spark-4d3339a3ecec2a910fc6a963e825bd7fb97919c5.tar.gz spark-4d3339a3ecec2a910fc6a963e825bd7fb97919c5.tar.bz2 spark-4d3339a3ecec2a910fc6a963e825bd7fb97919c5.zip | |
Merge pull request #217 from rxin/dev
Added a method to RDD to expose the ClassManifest.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/RDD.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/RDD.scala b/core/src/main/scala/spark/RDD.scala index d28f3593fe..efe248896a 100644 --- a/core/src/main/scala/spark/RDD.scala +++ b/core/src/main/scala/spark/RDD.scala @@ -68,6 +68,8 @@ abstract class RDD[T: ClassManifest](@transient sc: SparkContext) extends Serial def preferredLocations(split: Split): Seq[String] = Nil def context = sc + + def elementClassManifest: ClassManifest[T] = classManifest[T] // Get a unique ID for this RDD val id = sc.newRddId() |