[prev in list] [next in list] [prev in thread] [next in thread] 

List:       monetdb-checkins
Subject:    MonetDB: Jan2014 - re-aligned no_mitosis_pipe & sequential_pipe ...
From:       Stefan Manegold <commits () monetdb ! org>
Date:       2014-02-28 14:18:14
Message-ID: hg.90fef4269e60.1393597094.6315528441665844383 () monetdb2 ! cwi-incubator ! nl
[Download RAW message or body]

Changeset: 90fef4269e60 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=90fef4269e60
Modified Files:
	monetdb5/optimizer/opt_pipes.c
	sql/benchmarks/ssbm/Tests/04-explain.stable.out
	sql/benchmarks/ssbm/Tests/05-explain.stable.out
	sql/benchmarks/ssbm/Tests/06-explain.stable.out
	sql/benchmarks/ssbm/Tests/11-explain.stable.out
	sql/benchmarks/tpch/Tests/01-explain.stable.out
	sql/benchmarks/tpch/Tests/09-explain.stable.out
	sql/benchmarks/tpch/Tests/10-explain.stable.out
	sql/benchmarks/tpch/Tests/18-explain.stable.out
	sql/test/Tests/setoptimizer.stable.out
	sql/test/Tests/setoptimizer.stable.out.Windows
	tools/mserver/mserver5.1.in
Branch: Jan2014
Log Message:

re-aligned no_mitosis_pipe & sequential_pipe with default_pipe:
(re-)enabled optimizer.groups(); cf., changeset b9912110e7c5


diffs (truncated from 1137 to 300 lines):

diff --git a/monetdb5/optimizer/opt_pipes.c b/monetdb5/optimizer/opt_pipes.c
--- a/monetdb5/optimizer/opt_pipes.c
+++ b/monetdb5/optimizer/opt_pipes.c
@@ -108,7 +108,7 @@ struct PIPELINES {
 	 "optimizer.mergetable();"
 	 "optimizer.deadcode();"
 	 "optimizer.commonTerms();"
-	 //"optimizer.groups();"
+	 "optimizer.groups();"
 	 "optimizer.joinPath();"
 	 "optimizer.reorder();"
 	 "optimizer.deadcode();"
@@ -137,7 +137,7 @@ struct PIPELINES {
 	 "optimizer.mergetable();"
 	 "optimizer.deadcode();"
 	 "optimizer.commonTerms();"
-	 //"optimizer.groups();"
+	 "optimizer.groups();"
 	 "optimizer.joinPath();"
 	 "optimizer.reorder();"
 	 "optimizer.deadcode();"
diff --git a/sql/benchmarks/ssbm/Tests/04-explain.stable.out \
                b/sql/benchmarks/ssbm/Tests/04-explain.stable.out
--- a/sql/benchmarks/ssbm/Tests/04-explain.stable.out
+++ b/sql/benchmarks/ssbm/Tests/04-explain.stable.out
@@ -49,12 +49,12 @@ function user.s2_1{autoCommit=true}(A0:s
     X_16 := sql.projectdelta(X_5,X_8,X_11,r1_11,X_14);
     X_19 := sql.bind(X_4,"sys","part","p_category",0);
     X_17:bat[:oid,:oid]  := sql.tid(X_4,"sys","part");
-    X_159 := algebra.subselect(X_19,X_17,A0,A0,true,true,false);
+    X_156 := algebra.subselect(X_19,X_17,A0,A0,true,true,false);
     (X_21,r1_22) := sql.bind(X_4,"sys","part","p_category",2);
-    X_160 := algebra.subselect(r1_22,A0,A0,true,true,false);
+    X_157 := algebra.subselect(r1_22,A0,A0,true,true,false);
     X_23 := sql.bind(X_4,"sys","part","p_category",1);
-    X_161 := algebra.subselect(X_23,X_17,A0,A0,true,true,false);
-    X_24 := sql.subdelta(X_159,X_17,X_21,X_160,X_161);
+    X_158 := algebra.subselect(X_23,X_17,A0,A0,true,true,false);
+    X_24 := sql.subdelta(X_156,X_17,X_21,X_157,X_158);
     X_26 := X_24;
     (X_27,r1_31) := algebra.join(X_16,X_26);
     X_29 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_suppkey_fkey",0);
@@ -64,54 +64,53 @@ function user.s2_1{autoCommit=true}(A0:s
     X_35 := algebra.leftfetchjoin(X_27,X_34);
     X_39 := sql.bind(X_4,"sys","supplier","s_region",0);
     X_36:bat[:oid,:oid]  := sql.tid(X_4,"sys","supplier");
-    X_162 := algebra.subselect(X_39,X_36,A1,A1,true,true,false);
+    X_159 := algebra.subselect(X_39,X_36,A1,A1,true,true,false);
     (X_42,r1_47) := sql.bind(X_4,"sys","supplier","s_region",2);
-    X_163 := algebra.subselect(r1_47,A1,A1,true,true,false);
+    X_160 := algebra.subselect(r1_47,A1,A1,true,true,false);
     X_45 := sql.bind(X_4,"sys","supplier","s_region",1);
-    X_164 := algebra.subselect(X_45,X_36,A1,A1,true,true,false);
-    X_47 := sql.subdelta(X_162,X_36,X_42,X_163,X_164);
+    X_161 := algebra.subselect(X_45,X_36,A1,A1,true,true,false);
+    X_47 := sql.subdelta(X_159,X_36,X_42,X_160,X_161);
     X_49 := X_47;
     (X_50,r1_58) := algebra.join(X_35,X_49);
-    X_165 := algebra.leftfetchjoin(X_50,X_27);
+    X_162 := algebra.leftfetchjoin(X_50,X_27);
     X_52 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",0);
     (X_55,r1_63) := \
                sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",2);
                
     X_57 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",1);
     X_58 := sql.projectdelta(X_5,X_52,X_55,r1_63,X_57);
-    X_59:bat[:oid,:oid]  := algebra.leftfetchjoin(X_165,X_58);
+    X_59:bat[:oid,:oid]  := algebra.leftfetchjoin(X_162,X_58);
     X_60:bat[:oid,:oid]  := sql.tid(X_4,"sys","dwdate");
     (X_62,r1_72) := algebra.join(X_59,X_60);
-    X_166 := algebra.leftfetchjoin(X_62,X_50);
-    X_64 := sql.bind(X_4,"sys","part","p_brand1",0);
-    (X_68,r1_78) := sql.bind(X_4,"sys","part","p_brand1",2);
-    X_70 := sql.bind(X_4,"sys","part","p_brand1",1);
-    X_71 := sql.projectdelta(X_24,X_64,X_68,r1_78,X_70);
-    X_72:bat[:oid,:str]  := algebra.leftfetchjoinPath(X_166,r1_31,X_71);
     X_73 := sql.bind(X_4,"sys","dwdate","d_year",0);
     (X_76,r1_90) := sql.bind(X_4,"sys","dwdate","d_year",2);
     X_79 := sql.bind(X_4,"sys","dwdate","d_year",1);
     X_81 := sql.projectdelta(X_60,X_73,X_76,r1_90,X_79);
     X_82 := algebra.leftfetchjoin(r1_72,X_81);
-    (X_83,r1_98,r2_98) := group.subgroup(X_82);
-    (X_86,r1_101,r2_101) := group.subgroupdone(X_72,X_83);
-    X_89 := algebra.leftfetchjoin(r1_101,X_72);
-    X_90 := algebra.leftfetchjoin(r1_101,X_82);
-    X_98 := sql.bind(X_4,"sys","lineorder","lo_revenue",0);
-    (X_102,r1_117) := sql.bind(X_4,"sys","lineorder","lo_revenue",2);
-    X_104 := sql.bind(X_4,"sys","lineorder","lo_revenue",1);
-    X_105 := sql.projectdelta(X_5,X_98,X_102,r1_117,X_104);
-    X_106:bat[:oid,:int]  := algebra.leftfetchjoinPath(X_166,X_27,X_105);
-    X_107:bat[:oid,:lng]  := aggr.subsum(X_106,X_86,r1_101,true,true);
-    (X_91,r1_106,r2_106) := algebra.subsort(X_90,false,false);
-    (X_95,r1_110,r2_110) := algebra.subsort(X_89,r1_106,r2_106,false,false);
-    X_109 := algebra.leftfetchjoin(r1_110,X_107);
-    X_111 := algebra.leftfetchjoin(r1_110,X_89);
-    X_110 := algebra.leftfetchjoin(r1_110,X_90);
-    X_112 := sql.resultSet(3,1,X_109);
-    sql.rsColumn(X_112,"sys.L1","L1","bigint",32,0,X_109);
-    sql.rsColumn(X_112,"sys.dwdate","d_year","int",32,0,X_110);
-    sql.rsColumn(X_112,"sys.part","p_brand1","clob",0,0,X_111);
-    X_129 := io.stdout();
-    sql.exportResult(X_129,X_112);
+    X_163 := algebra.leftfetchjoin(X_62,X_50);
+    X_64 := sql.bind(X_4,"sys","part","p_brand1",0);
+    (X_68,r1_78) := sql.bind(X_4,"sys","part","p_brand1",2);
+    X_70 := sql.bind(X_4,"sys","part","p_brand1",1);
+    X_71 := sql.projectdelta(X_24,X_64,X_68,r1_78,X_70);
+    X_72:bat[:oid,:str]  := algebra.leftfetchjoinPath(X_163,r1_31,X_71);
+    (X_83,r1_101,r2_101) := group.subgroup(X_82,X_72);
+    X_86 := algebra.leftfetchjoin(r1_101,X_72);
+    X_87 := algebra.leftfetchjoin(r1_101,X_82);
+    X_95 := sql.bind(X_4,"sys","lineorder","lo_revenue",0);
+    (X_99,r1_117) := sql.bind(X_4,"sys","lineorder","lo_revenue",2);
+    X_101 := sql.bind(X_4,"sys","lineorder","lo_revenue",1);
+    X_102 := sql.projectdelta(X_5,X_95,X_99,r1_117,X_101);
+    X_103:bat[:oid,:int]  := algebra.leftfetchjoinPath(X_163,X_27,X_102);
+    X_104:bat[:oid,:lng]  := aggr.subsum(X_103,X_83,r1_101,true,true);
+    (X_88,r1_106,r2_106) := algebra.subsort(X_87,false,false);
+    (X_92,r1_110,r2_110) := algebra.subsort(X_86,r1_106,r2_106,false,false);
+    X_106 := algebra.leftfetchjoin(r1_110,X_104);
+    X_108 := algebra.leftfetchjoin(r1_110,X_86);
+    X_107 := algebra.leftfetchjoin(r1_110,X_87);
+    X_109 := sql.resultSet(3,1,X_106);
+    sql.rsColumn(X_109,"sys.L1","L1","bigint",32,0,X_106);
+    sql.rsColumn(X_109,"sys.dwdate","d_year","int",32,0,X_107);
+    sql.rsColumn(X_109,"sys.part","p_brand1","clob",0,0,X_108);
+    X_126 := io.stdout();
+    sql.exportResult(X_126,X_109);
 end s2_1;
 # querylog.define("explain\nselect sum(lo_revenue), d_year, p_brand1\n\tfrom \
lineorder, dwdate, part, supplier\n\twhere lo_orderdate = d_datekey\n\t\tand \
lo_partkey = p_partkey\n\t\tand lo_suppkey = s_suppkey\n\t\tand p_category = \
\\'MFGR#12\\' -- OK to add p_mfgr = 'MFGR#1'\n\t\tand s_region = \
\\'AMERICA\\'\n\tgroup by d_year, p_brand1\n\torder by d_year, \
p_brand1;","sequential_pipe")  
diff --git a/sql/benchmarks/ssbm/Tests/05-explain.stable.out \
                b/sql/benchmarks/ssbm/Tests/05-explain.stable.out
--- a/sql/benchmarks/ssbm/Tests/05-explain.stable.out
+++ b/sql/benchmarks/ssbm/Tests/05-explain.stable.out
@@ -51,12 +51,12 @@ function user.s2_1{autoCommit=true}(A0:s
     X_17 := sql.projectdelta(X_6,X_9,X_12,r1_12,X_15);
     X_20 := sql.bind(X_5,"sys","part","p_brand1",0);
     X_18:bat[:oid,:oid]  := sql.tid(X_5,"sys","part");
-    X_153 := algebra.subselect(X_20,X_18,A0,A1,true,true,false);
+    X_150 := algebra.subselect(X_20,X_18,A0,A1,true,true,false);
     (X_22,r1_23) := sql.bind(X_5,"sys","part","p_brand1",2);
-    X_154 := algebra.subselect(r1_23,A0,A1,true,true,false);
+    X_151 := algebra.subselect(r1_23,A0,A1,true,true,false);
     X_24 := sql.bind(X_5,"sys","part","p_brand1",1);
-    X_155 := algebra.subselect(X_24,X_18,A0,A1,true,true,false);
-    X_25 := sql.subdelta(X_153,X_18,X_22,X_154,X_155);
+    X_152 := algebra.subselect(X_24,X_18,A0,A1,true,true,false);
+    X_25 := sql.subdelta(X_150,X_18,X_22,X_151,X_152);
     X_27 := X_25;
     (X_28,r1_33) := algebra.join(X_17,X_27);
     X_30 := sql.bind_idxbat(X_5,"sys","lineorder","lineorder_lo_suppkey_fkey",0);
@@ -66,51 +66,50 @@ function user.s2_1{autoCommit=true}(A0:s
     X_38 := algebra.leftfetchjoin(X_28,X_37);
     X_41 := sql.bind(X_5,"sys","supplier","s_region",0);
     X_39:bat[:oid,:oid]  := sql.tid(X_5,"sys","supplier");
-    X_156 := algebra.subselect(X_41,X_39,A2,A2,true,true,false);
+    X_153 := algebra.subselect(X_41,X_39,A2,A2,true,true,false);
     (X_44,r1_50) := sql.bind(X_5,"sys","supplier","s_region",2);
-    X_157 := algebra.subselect(r1_50,A2,A2,true,true,false);
+    X_154 := algebra.subselect(r1_50,A2,A2,true,true,false);
     X_47 := sql.bind(X_5,"sys","supplier","s_region",1);
-    X_158 := algebra.subselect(X_47,X_39,A2,A2,true,true,false);
-    X_49 := sql.subdelta(X_156,X_39,X_44,X_157,X_158);
+    X_155 := algebra.subselect(X_47,X_39,A2,A2,true,true,false);
+    X_49 := sql.subdelta(X_153,X_39,X_44,X_154,X_155);
     X_51 := X_49;
     (X_52,r1_61) := algebra.join(X_38,X_51);
-    X_159 := algebra.leftfetchjoin(X_52,X_28);
+    X_156 := algebra.leftfetchjoin(X_52,X_28);
     X_54 := sql.bind_idxbat(X_5,"sys","lineorder","lineorder_lo_orderdate_fkey",0);
     (X_56,r1_65) := \
                sql.bind_idxbat(X_5,"sys","lineorder","lineorder_lo_orderdate_fkey",2);
                
     X_58 := sql.bind_idxbat(X_5,"sys","lineorder","lineorder_lo_orderdate_fkey",1);
     X_59 := sql.projectdelta(X_6,X_54,X_56,r1_65,X_58);
-    X_60:bat[:oid,:oid]  := algebra.leftfetchjoin(X_159,X_59);
+    X_60:bat[:oid,:oid]  := algebra.leftfetchjoin(X_156,X_59);
     X_61:bat[:oid,:oid]  := sql.tid(X_5,"sys","dwdate");
     (X_64,r1_75) := algebra.join(X_60,X_61);
-    X_160 := algebra.leftfetchjoin(X_64,X_52);
-    X_66 := sql.projectdelta(X_25,X_20,X_22,r1_23,X_24);
-    X_67:bat[:oid,:str]  := algebra.leftfetchjoinPath(X_160,r1_33,X_66);
     X_68 := sql.bind(X_5,"sys","dwdate","d_year",0);
     (X_71,r1_84) := sql.bind(X_5,"sys","dwdate","d_year",2);
     X_74 := sql.bind(X_5,"sys","dwdate","d_year",1);
     X_76 := sql.projectdelta(X_61,X_68,X_71,r1_84,X_74);
     X_77 := algebra.leftfetchjoin(r1_75,X_76);
-    (X_78,r1_92,r2_92) := group.subgroup(X_77);
-    (X_81,r1_95,r2_95) := group.subgroupdone(X_67,X_78);
-    X_84 := algebra.leftfetchjoin(r1_95,X_67);
-    X_85 := algebra.leftfetchjoin(r1_95,X_77);
-    X_93 := sql.bind(X_5,"sys","lineorder","lo_revenue",0);
-    (X_97,r1_111) := sql.bind(X_5,"sys","lineorder","lo_revenue",2);
-    X_99 := sql.bind(X_5,"sys","lineorder","lo_revenue",1);
-    X_100 := sql.projectdelta(X_6,X_93,X_97,r1_111,X_99);
-    X_101:bat[:oid,:int]  := algebra.leftfetchjoinPath(X_160,X_28,X_100);
-    X_102:bat[:oid,:lng]  := aggr.subsum(X_101,X_81,r1_95,true,true);
-    (X_86,r1_100,r2_100) := algebra.subsort(X_85,false,false);
-    (X_90,r1_104,r2_104) := algebra.subsort(X_84,r1_100,r2_100,false,false);
-    X_104 := algebra.leftfetchjoin(r1_104,X_102);
-    X_106 := algebra.leftfetchjoin(r1_104,X_84);
-    X_105 := algebra.leftfetchjoin(r1_104,X_85);
-    X_107 := sql.resultSet(3,1,X_104);
-    sql.rsColumn(X_107,"sys.L1","L1","bigint",32,0,X_104);
-    sql.rsColumn(X_107,"sys.dwdate","d_year","int",32,0,X_105);
-    sql.rsColumn(X_107,"sys.part","p_brand1","clob",0,0,X_106);
-    X_124 := io.stdout();
-    sql.exportResult(X_124,X_107);
+    X_157 := algebra.leftfetchjoin(X_64,X_52);
+    X_66 := sql.projectdelta(X_25,X_20,X_22,r1_23,X_24);
+    X_67:bat[:oid,:str]  := algebra.leftfetchjoinPath(X_157,r1_33,X_66);
+    (X_78,r1_95,r2_95) := group.subgroup(X_77,X_67);
+    X_81 := algebra.leftfetchjoin(r1_95,X_67);
+    X_82 := algebra.leftfetchjoin(r1_95,X_77);
+    X_90 := sql.bind(X_5,"sys","lineorder","lo_revenue",0);
+    (X_94,r1_111) := sql.bind(X_5,"sys","lineorder","lo_revenue",2);
+    X_96 := sql.bind(X_5,"sys","lineorder","lo_revenue",1);
+    X_97 := sql.projectdelta(X_6,X_90,X_94,r1_111,X_96);
+    X_98:bat[:oid,:int]  := algebra.leftfetchjoinPath(X_157,X_28,X_97);
+    X_99:bat[:oid,:lng]  := aggr.subsum(X_98,X_78,r1_95,true,true);
+    (X_83,r1_100,r2_100) := algebra.subsort(X_82,false,false);
+    (X_87,r1_104,r2_104) := algebra.subsort(X_81,r1_100,r2_100,false,false);
+    X_101 := algebra.leftfetchjoin(r1_104,X_99);
+    X_103 := algebra.leftfetchjoin(r1_104,X_81);
+    X_102 := algebra.leftfetchjoin(r1_104,X_82);
+    X_104 := sql.resultSet(3,1,X_101);
+    sql.rsColumn(X_104,"sys.L1","L1","bigint",32,0,X_101);
+    sql.rsColumn(X_104,"sys.dwdate","d_year","int",32,0,X_102);
+    sql.rsColumn(X_104,"sys.part","p_brand1","clob",0,0,X_103);
+    X_121 := io.stdout();
+    sql.exportResult(X_121,X_104);
 end s2_1;
 # querylog.define("explain\nselect sum(lo_revenue), d_year, p_brand1\n\tfrom \
lineorder, dwdate, part, supplier\n\twhere lo_orderdate = d_datekey\n\t\tand \
lo_partkey = p_partkey\n\t\tand lo_suppkey = s_suppkey\n\t\t-- OK to add \
p_mfgr='MFGR#2'\n\t\t-- OK to add p_category='MFGR#22'\n\t\tand p_brand1 between \
\\'MFGR#2221\\' and \\'MFGR#2228\\'\n\t\tand s_region = \\'ASIA\\'\n\tgroup by \
d_year, p_brand1\n\torder by d_year, p_brand1;","sequential_pipe")  
diff --git a/sql/benchmarks/ssbm/Tests/06-explain.stable.out \
                b/sql/benchmarks/ssbm/Tests/06-explain.stable.out
--- a/sql/benchmarks/ssbm/Tests/06-explain.stable.out
+++ b/sql/benchmarks/ssbm/Tests/06-explain.stable.out
@@ -51,12 +51,12 @@ function user.s2_1{autoCommit=true}(A0:s
     X_16 := sql.projectdelta(X_5,X_8,X_11,r1_11,X_14);
     X_19 := sql.bind(X_4,"sys","part","p_brand1",0);
     X_17:bat[:oid,:oid]  := sql.tid(X_4,"sys","part");
-    X_151 := algebra.subselect(X_19,X_17,A0,A0,true,true,false);
+    X_148 := algebra.subselect(X_19,X_17,A0,A0,true,true,false);
     (X_21,r1_22) := sql.bind(X_4,"sys","part","p_brand1",2);
-    X_152 := algebra.subselect(r1_22,A0,A0,true,true,false);
+    X_149 := algebra.subselect(r1_22,A0,A0,true,true,false);
     X_23 := sql.bind(X_4,"sys","part","p_brand1",1);
-    X_153 := algebra.subselect(X_23,X_17,A0,A0,true,true,false);
-    X_24 := sql.subdelta(X_151,X_17,X_21,X_152,X_153);
+    X_150 := algebra.subselect(X_23,X_17,A0,A0,true,true,false);
+    X_24 := sql.subdelta(X_148,X_17,X_21,X_149,X_150);
     X_26 := X_24;
     (X_27,r1_31) := algebra.join(X_16,X_26);
     X_29 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_suppkey_fkey",0);
@@ -66,51 +66,50 @@ function user.s2_1{autoCommit=true}(A0:s
     X_35 := algebra.leftfetchjoin(X_27,X_34);
     X_39 := sql.bind(X_4,"sys","supplier","s_region",0);
     X_36:bat[:oid,:oid]  := sql.tid(X_4,"sys","supplier");
-    X_154 := algebra.subselect(X_39,X_36,A1,A1,true,true,false);
+    X_151 := algebra.subselect(X_39,X_36,A1,A1,true,true,false);
     (X_42,r1_47) := sql.bind(X_4,"sys","supplier","s_region",2);
-    X_155 := algebra.subselect(r1_47,A1,A1,true,true,false);
+    X_152 := algebra.subselect(r1_47,A1,A1,true,true,false);
     X_45 := sql.bind(X_4,"sys","supplier","s_region",1);
-    X_156 := algebra.subselect(X_45,X_36,A1,A1,true,true,false);
-    X_47 := sql.subdelta(X_154,X_36,X_42,X_155,X_156);
+    X_153 := algebra.subselect(X_45,X_36,A1,A1,true,true,false);
+    X_47 := sql.subdelta(X_151,X_36,X_42,X_152,X_153);
     X_49 := X_47;
     (X_50,r1_58) := algebra.join(X_35,X_49);
-    X_157 := algebra.leftfetchjoin(X_50,X_27);
+    X_154 := algebra.leftfetchjoin(X_50,X_27);
     X_52 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",0);
     (X_55,r1_63) := \
                sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",2);
                
     X_57 := sql.bind_idxbat(X_4,"sys","lineorder","lineorder_lo_orderdate_fkey",1);
     X_58 := sql.projectdelta(X_5,X_52,X_55,r1_63,X_57);
-    X_59:bat[:oid,:oid]  := algebra.leftfetchjoin(X_157,X_58);
+    X_59:bat[:oid,:oid]  := algebra.leftfetchjoin(X_154,X_58);
     X_60:bat[:oid,:oid]  := sql.tid(X_4,"sys","dwdate");
     (X_62,r1_72) := algebra.join(X_59,X_60);
-    X_158 := algebra.leftfetchjoin(X_62,X_50);
-    X_64 := sql.projectdelta(X_24,X_19,X_21,r1_22,X_23);
-    X_65:bat[:oid,:str]  := algebra.leftfetchjoinPath(X_158,r1_31,X_64);
     X_66 := sql.bind(X_4,"sys","dwdate","d_year",0);
     (X_70,r1_82) := sql.bind(X_4,"sys","dwdate","d_year",2);
     X_73 := sql.bind(X_4,"sys","dwdate","d_year",1);
     X_75 := sql.projectdelta(X_60,X_66,X_70,r1_82,X_73);
     X_76 := algebra.leftfetchjoin(r1_72,X_75);
-    (X_77,r1_90,r2_90) := group.subgroup(X_76);
-    (X_80,r1_93,r2_93) := group.subgroupdone(X_65,X_77);
-    X_83 := algebra.leftfetchjoin(r1_93,X_65);
-    X_84 := algebra.leftfetchjoin(r1_93,X_76);
-    X_92 := sql.bind(X_4,"sys","lineorder","lo_revenue",0);
-    (X_95,r1_108) := sql.bind(X_4,"sys","lineorder","lo_revenue",2);
-    X_97 := sql.bind(X_4,"sys","lineorder","lo_revenue",1);
-    X_98 := sql.projectdelta(X_5,X_92,X_95,r1_108,X_97);
-    X_99:bat[:oid,:int]  := algebra.leftfetchjoinPath(X_158,X_27,X_98);
-    X_100:bat[:oid,:lng]  := aggr.subsum(X_99,X_80,r1_93,true,true);
-    (X_85,r1_98,r2_98) := algebra.subsort(X_84,false,false);
-    (X_89,r1_102,r2_102) := algebra.subsort(X_83,r1_98,r2_98,false,false);
-    X_102 := algebra.leftfetchjoin(r1_102,X_100);
-    X_104 := algebra.leftfetchjoin(r1_102,X_83);
-    X_103 := algebra.leftfetchjoin(r1_102,X_84);
-    X_105 := sql.resultSet(3,1,X_102);
-    sql.rsColumn(X_105,"sys.L1","L1","bigint",32,0,X_102);
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list


[prev in list] [next in list] [prev in thread] [next in thread] 

Configure | About | News | Add a list | Sponsored by KoreLogic