Skip to content

Commit 307695e

Browse files
committed
add .schemaRDD to JavaSchemaRDD
1 parent cb0eae3 commit 307695e

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)