You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by me...@apache.org on 2014/11/06 04:56:20 UTC
git commit: [SPARK-4262][SQL] add .schemaRDD to JavaSchemaRDD
Repository: spark
Updated Branches:
refs/heads/master c315d1316 -> 3d2b5bc5b
[SPARK-4262][SQL] add .schemaRDD to JavaSchemaRDD
marmbrus
Author: Xiangrui Meng <me...@databricks.com>
Closes #3125 from mengxr/SPARK-4262 and squashes the following commits:
307695e [Xiangrui Meng] add .schemaRDD to JavaSchemaRDD
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3d2b5bc5
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3d2b5bc5
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3d2b5bc5
Branch: refs/heads/master
Commit: 3d2b5bc5bb979d8b0b71e06bc0f4548376fdbb98
Parents: c315d13
Author: Xiangrui Meng <me...@databricks.com>
Authored: Wed Nov 5 19:56:16 2014 -0800
Committer: Xiangrui Meng <me...@databricks.com>
Committed: Wed Nov 5 19:56:16 2014 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/3d2b5bc5/sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala
index 1e0ccb3..78e8d90 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/api/java/JavaSchemaRDD.scala
@@ -47,6 +47,9 @@ class JavaSchemaRDD(
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 def wrapRDD(rdd: RDD[Row]): JavaRDD[Row] = JavaRDD.fromRDD(rdd)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org