Skip to content
Snippets Groups Projects
Commit 3d2b5bc5 authored by Xiangrui Meng's avatar Xiangrui Meng
Browse files

[SPARK-4262][SQL] add .schemaRDD to JavaSchemaRDD

 marmbrus

Author: Xiangrui Meng <meng@databricks.com>

Closes #3125 from mengxr/SPARK-4262 and squashes the following commits:

307695e [Xiangrui Meng] add .schemaRDD to JavaSchemaRDD
parent c315d131
No related branches found
No related tags found
No related merge requests found
...@@ -47,6 +47,9 @@ class JavaSchemaRDD( ...@@ -47,6 +47,9 @@ class JavaSchemaRDD(
private[sql] val baseSchemaRDD = new SchemaRDD(sqlContext, logicalPlan) private[sql] val baseSchemaRDD = new SchemaRDD(sqlContext, logicalPlan)
/** Returns the underlying Scala SchemaRDD. */
val schemaRDD: SchemaRDD = baseSchemaRDD
override val classTag = scala.reflect.classTag[Row] override val classTag = scala.reflect.classTag[Row]
override def wrapRDD(rdd: RDD[Row]): JavaRDD[Row] = JavaRDD.fromRDD(rdd) override def wrapRDD(rdd: RDD[Row]): JavaRDD[Row] = JavaRDD.fromRDD(rdd)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment