You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2015/04/14 03:23:39 UTC
spark git commit: [SQL] [Minor] Fix for SqlApp.scala
Repository: spark
Updated Branches:
refs/heads/master 435b8779d -> 3782e1f2b
[SQL] [Minor] Fix for SqlApp.scala
SqlApp.scala is out of date.
Author: Fei Wang <wa...@huawei.com>
Closes #5485 from scwf/patch-1 and squashes the following commits:
6f731c2 [Fei Wang] SqlApp.scala compile error
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3782e1f2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3782e1f2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3782e1f2
Branch: refs/heads/master
Commit: 3782e1f2bec07b5ffbc8503e40591e96fce67256
Parents: 435b877
Author: Fei Wang <wa...@huawei.com>
Authored: Mon Apr 13 18:23:35 2015 -0700
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Mon Apr 13 18:23:35 2015 -0700
----------------------------------------------------------------------
dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/3782e1f2/dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala
----------------------------------------------------------------------
diff --git a/dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala b/dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala
index d888de9..cc86ef4 100644
--- a/dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala
+++ b/dev/audit-release/sbt_app_sql/src/main/scala/SqlApp.scala
@@ -36,8 +36,10 @@ object SparkSqlExample {
val sc = new SparkContext(conf)
val sqlContext = new SQLContext(sc)
+ import sqlContext.implicits._
import sqlContext._
- val people = sc.makeRDD(1 to 100, 10).map(x => Person(s"Name$x", x))
+
+ val people = sc.makeRDD(1 to 100, 10).map(x => Person(s"Name$x", x)).toDF()
people.registerTempTable("people")
val teenagers = sql("SELECT name FROM people WHERE age >= 13 AND age <= 19")
val teenagerNames = teenagers.map(t => "Name: " + t(0)).collect()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org