aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTijo Thomas <tijoparacka@gmail.com>2015-04-08 13:42:29 -0700
committerReynold Xin <rxin@databricks.com>2015-04-08 13:43:05 -0700
commit4453c591a2eaa9381766f6155bfd3e7749f721e0 (patch)
tree2c74904fbdd331b2c412ea08bb1e84d4c58387f9
parente1afd479b3446483e6e1626afdec549cc214d80e (diff)
downloadspark-4453c591a2eaa9381766f6155bfd3e7749f721e0.tar.gz
spark-4453c591a2eaa9381766f6155bfd3e7749f721e0.tar.bz2
spark-4453c591a2eaa9381766f6155bfd3e7749f721e0.zip
[SPARK-6767][SQL] Fixed Query DSL error in spark sql Readme
Fixed the following error query.where('key > 30).select(avg('key)).collect() <console>:43: error: value > is not a member of Symbol query.where('key > 30).select(avg('key)).collect() Author: Tijo Thomas <tijoparacka@gmail.com> Closes #5415 from tijoparacka/ERROR_SQL_DATAFRAME_EXAMPLE and squashes the following commits: 234751e [Tijo Thomas] Fixed Query DSL error in spark sql Readme (cherry picked from commit 2f482d706b9d38820472c3152dbd1612c98729bd) Signed-off-by: Reynold Xin <rxin@databricks.com>
-rw-r--r--sql/README.md2
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/README.md b/sql/README.md
index a79249965e..0125de61f8 100644
--- a/sql/README.md
+++ b/sql/README.md
@@ -57,6 +57,6 @@ res2: Array[org.apache.spark.sql.Row] = Array([238,val_238], [86,val_86], [311,v
You can also build further queries on top of these `DataFrames` using the query DSL.
```
-scala> query.where('key > 30).select(avg('key)).collect()
+scala> query.where(query("key") > 30).select(avg(query("key"))).collect()
res3: Array[org.apache.spark.sql.Row] = Array([274.79025423728814])
```