ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-5457][SQL] Add missing DSL for ApproxCountDistinct.

Browse source 
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.
This commit is contained in:
Takuya UESHIN 2015-01-30 01:21:35 -08:00 committed by Reynold Xin
parent bc1fc9b60d
commit 6f21dce5f4
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
sql/core/src/main/scala/org/apache/spark/sql/Dsl.scala
View file

@ -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)