diff options
author | Tijo Thomas <tijoparacka@gmail.com> | 2015-04-08 13:42:29 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-04-08 13:42:29 -0700 |
commit | 2f482d706b9d38820472c3152dbd1612c98729bd (patch) | |
tree | f7282ba271bc97515b8ab40dcb8c76c60d143cdc /sql | |
parent | 6ada4f6f52cf1d992c7ab0c32318790cf08b0a0d (diff) | |
download | spark-2f482d706b9d38820472c3152dbd1612c98729bd.tar.gz spark-2f482d706b9d38820472c3152dbd1612c98729bd.tar.bz2 spark-2f482d706b9d38820472c3152dbd1612c98729bd.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
Diffstat (limited to 'sql')
-rw-r--r-- | sql/README.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/README.md b/sql/README.md index fbb3200a3a..237620e3fa 100644 --- a/sql/README.md +++ b/sql/README.md @@ -56,6 +56,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]) ``` |