diff options
| author | Takuya UESHIN <ueshin@happy-camper.st> | 2015-01-30 01:21:35 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-01-30 01:21:35 -0800 |
| commit | 6f21dce5f4619e1a5d07028e2a74dc36be0849b9 (patch) | |
| tree | 8abf5df4ee32feb19d1232f41c2fcc5a1ba273b0 /sql | |
| parent | bc1fc9b60dab69ae74419e35dc6bd263dc504f34 (diff) | |
| download | spark-6f21dce5f4619e1a5d07028e2a74dc36be0849b9.tar.gz spark-6f21dce5f4619e1a5d07028e2a74dc36be0849b9.tar.bz2 spark-6f21dce5f4619e1a5d07028e2a74dc36be0849b9.zip | |
[SPARK-5457][SQL] Add missing DSL for ApproxCountDistinct.
Author: Takuya UESHIN <ueshin@happy-camper.st>
Closes #4250 from ueshin/issues/SPARK-5457 and squashes the following commits:
3c05e59 [Takuya UESHIN] Remove parameter to use default value of ApproxCountDistinct.
faea19d [Takuya UESHIN] Use overload instead of default value for Java support.
d1cca38 [Takuya UESHIN] Merge branch 'master' into issues/SPARK-5457
663d43d [Takuya UESHIN] Add missing DSL for ApproxCountDistinct.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala b/sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala index 75717e7cd8..3499956023 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala @@ -105,6 +105,11 @@ object Dsl { def countDistinct(expr: Column, exprs: Column*): Column = CountDistinct((expr +: exprs).map(_.expr)) + def approxCountDistinct(e: Column): Column = + ApproxCountDistinct(e.expr) + def approxCountDistinct(e: Column, rsd: Double): Column = + ApproxCountDistinct(e.expr, rsd) + def avg(e: Column): Column = Average(e.expr) def first(e: Column): Column = First(e.expr) def last(e: Column): Column = Last(e.expr) |