Skip to content

Commit

Permalink
Tweak
Browse files Browse the repository at this point in the history
  • Loading branch information
krlmlr committed Aug 5, 2023
1 parent 9c8affa commit 5654fc1
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
12 changes: 6 additions & 6 deletions R/summarise.R
Original file line number Diff line number Diff line change
Expand Up @@ -6,20 +6,20 @@ summarise.duckplyr_df <- function(.data, ..., .by = NULL, .groups = NULL) {
rel_try(
'summarize(.groups = "rowwise") not supported' = identical(.groups, "rowwise"),
{
rel <- duckdb_rel_from_df(.data)

by <- eval_select_by(enquo(.by), .data)
oo <- (length(by) > 0) && oo_force()

rel <- duckdb_rel_from_df(.data)
dots <- dplyr_quosures(...)
dots <- fix_auto_name(dots)

oo <- (length(by) > 0) && oo_force()
if (oo) {
rel <- oo_prep(rel, colname = "___row_number", force = TRUE)
}

dots <- dplyr_quosures(...)
dots <- fix_auto_name(dots)

aggregates <- rel_translate_dots(dots, .data)
groups <- lapply(by, relexpr_reference)
aggregates <- rel_translate_dots(dots, .data)

if (oo) {
aggregates <- c(
Expand Down
14 changes: 7 additions & 7 deletions patch/summarise.patch
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
diff --git b/R/summarise.R a/R/summarise.R
index 482068f..37ab950 100644
index 482068f..aea4a71 100644
--- b/R/summarise.R
+++ a/R/summarise.R
@@ -1,10 +1,50 @@
Expand All @@ -13,20 +13,20 @@ index 482068f..37ab950 100644
- "No relational implementation for summarise()" = TRUE,
+ 'summarize(.groups = "rowwise") not supported' = identical(.groups, "rowwise"),
{
+ rel <- duckdb_rel_from_df(.data)
+
+ by <- eval_select_by(enquo(.by), .data)
+ oo <- (length(by) > 0) && oo_force()
+
+ rel <- duckdb_rel_from_df(.data)
+ dots <- dplyr_quosures(...)
+ dots <- fix_auto_name(dots)
+
+ oo <- (length(by) > 0) && oo_force()
+ if (oo) {
+ rel <- oo_prep(rel, colname = "___row_number", force = TRUE)
+ }
+
+ dots <- dplyr_quosures(...)
+ dots <- fix_auto_name(dots)
+
+ aggregates <- rel_translate_dots(dots, .data)
+ groups <- lapply(by, relexpr_reference)
+ aggregates <- rel_translate_dots(dots, .data)
+
+ if (oo) {
+ aggregates <- c(
Expand Down

0 comments on commit 5654fc1

Please sign in to comment.