Changeset: efe34fc61c06 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=efe34fc61c06
Modified Files:
        MonetDB5/src/optimizer/opt_mapreduce.mx
Branch: default
Log Message:

don't push comments to the reduce plan, as it is delayed, hence the comments 
would appear before the signature


diffs (27 lines):

diff -r 7728f6493cdd -r efe34fc61c06 MonetDB5/src/optimizer/opt_mapreduce.mx
--- a/MonetDB5/src/optimizer/opt_mapreduce.mx   Wed Jun 09 11:27:02 2010 +0200
+++ b/MonetDB5/src/optimizer/opt_mapreduce.mx   Wed Jun 09 11:41:59 2010 +0200
@@ -656,7 +656,6 @@
                                if (getArg(p, 1) == lastcol->reduceid) {
                                        copy = SINGLE_DUP;
                                        newComment(map, "ORDER BY [DESC] or 
LIMIT/OFFSET");
-                                       newComment(reduce, "ORDER BY [DESC] or 
LIMIT/OFFSET");
                                        /* fix return */
                                        lastcol->mapid = getArg(omap[i], 0);
                                        lastcol->reduceid = getArg(p, 0);
@@ -671,7 +670,6 @@
                        for (lastcol = col; lastcol != NULL; lastcol = 
lastcol->next) { 
                                if (getArg(p, 1) == lastcol->reduceid) {
                                        newComment(map, "MAX/MIN");
-                                       newComment(reduce, "MAX/MIN");
                                        /* basically perform a MAX over all 
MAXes */
                                        pushInstruction(map, omap[i]);
                                        lastcol->mapid = getArg(omap[i], 0);
@@ -711,7 +709,6 @@
                        for (lastcol = col; lastcol != NULL; lastcol = 
lastcol->next) { 
                                if (getArg(p, 1) == lastcol->reduceid) {
                                        newComment(map, "COUNT/SUM");
-                                       newComment(reduce, "COUNT/SUM");
                                        pushInstruction(map, omap[i]);
                                        lastcol->mapid = getArg(omap[i], 0);
 
_______________________________________________
Checkin-list mailing list
[email protected]
http://mail.monetdb.org/mailman/listinfo/checkin-list

Reply via email to