diff options
| author | Reynold Xin <rxin@cs.berkeley.edu> | 2012-09-24 16:56:27 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@cs.berkeley.edu> | 2012-09-24 16:56:27 -0700 |
| commit | 348bcbca1f12fb4c042c85af792b14426d46e9bd (patch) | |
| tree | 1e98a9351f6209c4745af8a23dcfd2dc2afcc373 | |
| parent | f855e4fad2b298641b6a6ae4ef74bd1e000f028d (diff) | |
| download | spark-348bcbca1f12fb4c042c85af792b14426d46e9bd.tar.gz spark-348bcbca1f12fb4c042c85af792b14426d46e9bd.tar.bz2 spark-348bcbca1f12fb4c042c85af792b14426d46e9bd.zip | |
Added a method to RDD to expose the ClassManifest.
| -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..b413ee21c9 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 manifest: ClassManifest[T] = classManifest[T] // Get a unique ID for this RDD val id = sc.newRddId() |