Skip to content

Commit 3d2b5bc

Browse files
committed
[SPARK-4262][SQL] add .schemaRDD to JavaSchemaRDD
marmbrus Author: Xiangrui Meng <[email protected]> Closes #3125 from mengxr/SPARK-4262 and squashes the following commits: 307695e [Xiangrui Meng] add .schemaRDD to JavaSchemaRDD
1 parent c315d13 commit 3d2b5bc

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,9 @@ class JavaSchemaRDD(
4747

4848
private[sql] val baseSchemaRDD = new SchemaRDD(sqlContext, logicalPlan)
4949

50+
/** Returns the underlying Scala SchemaRDD. */
51+
val schemaRDD: SchemaRDD = baseSchemaRDD
52+
5053
override val classTag = scala.reflect.classTag[Row]
5154

5255
override def wrapRDD(rdd: RDD[Row]): JavaRDD[Row] = JavaRDD.fromRDD(rdd)

0 commit comments

Comments
 (0)