diff options
| author | Yin Huai <yhuai@databricks.com> | 2015-11-10 11:06:29 -0800 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-11-10 11:06:29 -0800 |
| commit | e0701c75601c43f69ed27fc7c252321703db51f2 (patch) | |
| tree | 52d85dfefce3da304fef585c895667f305cd8238 /R | |
| parent | 6e5fc37883ed81c3ee2338145a48de3036d19399 (diff) | |
| download | spark-e0701c75601c43f69ed27fc7c252321703db51f2.tar.gz spark-e0701c75601c43f69ed27fc7c252321703db51f2.tar.bz2 spark-e0701c75601c43f69ed27fc7c252321703db51f2.zip | |
[SPARK-9830][SQL] Remove AggregateExpression1 and Aggregate Operator used to evaluate AggregateExpression1s
https://issues.apache.org/jira/browse/SPARK-9830
This PR contains the following main changes.
* Removing `AggregateExpression1`.
* Removing `Aggregate` operator, which is used to evaluate `AggregateExpression1`.
* Removing planner rule used to plan `Aggregate`.
* Linking `MultipleDistinctRewriter` to analyzer.
* Renaming `AggregateExpression2` to `AggregateExpression` and `AggregateFunction2` to `AggregateFunction`.
* Updating places where we create aggregate expression. The way to create aggregate expressions is `AggregateExpression(aggregateFunction, mode, isDistinct)`.
* Changing `val`s in `DeclarativeAggregate`s that touch children of this function to `lazy val`s (when we create aggregate expression in DataFrame API, children of an aggregate function can be unresolved).
Author: Yin Huai <yhuai@databricks.com>
Closes #9556 from yhuai/removeAgg1.
Diffstat (limited to 'R')
| -rw-r--r-- | R/pkg/R/functions.R | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/R/pkg/R/functions.R b/R/pkg/R/functions.R index d7fd279279..0b28087029 100644 --- a/R/pkg/R/functions.R +++ b/R/pkg/R/functions.R @@ -1339,7 +1339,7 @@ setMethod("pmod", signature(y = "Column"), #' @export setMethod("approxCountDistinct", signature(x = "Column"), - function(x, rsd = 0.95) { + function(x, rsd = 0.05) { jc <- callJStatic("org.apache.spark.sql.functions", "approxCountDistinct", x@jc, rsd) column(jc) }) |