Changeset: 05228969b33e for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/05228969b33e
Modified Files:
sql/backends/monet5/bin_partition_by_slice.c
Branch: pp_hashjoin
Log Message:
handle group unique with partitioning
diffs (25 lines):
diff --git a/sql/backends/monet5/bin_partition_by_slice.c
b/sql/backends/monet5/bin_partition_by_slice.c
--- a/sql/backends/monet5/bin_partition_by_slice.c
+++ b/sql/backends/monet5/bin_partition_by_slice.c
@@ -463,7 +463,6 @@ rel_groupby_prepare_pp(list **aggrresult
if ((BUN)estimate > est)
estimate = est;
- assert(!nrparts);
stmt *s = stmt_oahash_new(be, t,
nrparts?PARTITION_NRPARTS:estimate, curhash, nrparts);
if (s == NULL)
return NULL;
@@ -1104,6 +1103,13 @@ rel2bin_groupby_pp(backend *be, sql_rel
aggrstmt->key = 1;
}
}
+ if (aggrexp->shared && nrparts) { /* make sure we have fetched
the output for group unique */
+ InstrPtr mp = newStmt(be->mb, "mat", "fetch");
+ mp = pushArgument(be->mb, mp, aggrexp->shared);
+ mp = pushArgument(be->mb, mp, be->pp);
+ pushInstruction(be->mb, mp);
+ aggrexp->shared = getArg(mp, 0);
+ }
if (!aggrstmt)
aggrstmt = exp_bin(be, aggrexp, sub, NULL, grp, ext,
NULL, NULL, 0, 0, 0);
_______________________________________________
checkin-list mailing list -- [email protected]
To unsubscribe send an email to [email protected]
