Line data Source code
1 : /*
2 : * SPDX-License-Identifier: MPL-2.0
3 : *
4 : * This Source Code Form is subject to the terms of the Mozilla Public
5 : * License, v. 2.0. If a copy of the MPL was not distributed with this
6 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
7 : *
8 : * Copyright 2024 MonetDB Foundation;
9 : * Copyright August 2008 - 2023 MonetDB B.V.;
10 : * Copyright 1997 - July 2008 CWI.
11 : */
12 :
13 : /*
14 : * Martin Kersten
15 : * Multiple association tables
16 : * A MAT is a convenient way to deal represent horizontal fragmented
17 : * tables. It combines the definitions of several, type compatible
18 : * BATs under a single name.
19 : * It is produced by the mitosis optimizer and the operations
20 : * are the target of the mergetable optimizer.
21 : *
22 : * The MAT is materialized when the operations
23 : * can not deal with the components individually,
24 : * or the incremental operation is not supported.
25 : * Normally all mat.new() operations are removed by the
26 : * mergetable optimizer.
27 : * In case a mat.new() is retained in the code, then it will
28 : * behave as a mat.pack();
29 : *
30 : * The primitives below are chosen to accommodate the SQL
31 : * front-end to produce reasonable efficient code.
32 : */
33 : #include "monetdb_config.h"
34 : #include "mal_resolve.h"
35 : #include "mal_exception.h"
36 : #include "mal_interpreter.h"
37 :
38 : /*
39 : * The pack is an ordinary multi BAT insert. Oid synchronistion
40 : * between pieces should be ensured by the code generators.
41 : * The pack operation could be quite expensive, because it
42 : * may create a really large BAT.
43 : * The slice over a mat helps to avoid constructing intermediates
44 : * that are subsequently reduced.
45 : * Contrary to most operations, NIL arguments are skipped and
46 : * do not produce RUNTIME_OBJECT_MISSING.
47 : */
48 : static str
49 79946 : MATpackInternal(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr p)
50 : {
51 79946 : int i;
52 79946 : bat *ret = getArgReference_bat(stk, p, 0);
53 79946 : BAT *b, *bn = NULL;
54 79946 : BUN cap = 0;
55 79946 : int tt = TYPE_any;
56 79946 : int rt = getArgType(mb, p, 0), unmask = 0;
57 79946 : (void) cntxt;
58 :
59 717394 : for (i = 1; i < p->argc; i++) {
60 637400 : bat bid = stk->stk[getArg(p, i)].val.bval;
61 637400 : b = BBPquickdesc(bid);
62 637448 : if (b) {
63 637448 : if (tt == TYPE_any)
64 79966 : tt = b->ttype;
65 637448 : if ((tt != TYPE_void && b->ttype != TYPE_void
66 621228 : && b->ttype != TYPE_msk) && tt != b->ttype)
67 0 : throw(MAL, "mat.pack", "incompatible arguments");
68 637448 : cap += BATcount(b);
69 : }
70 : }
71 79994 : if (tt == TYPE_any) {
72 0 : *ret = bat_nil;
73 0 : return MAL_SUCCEED;
74 : }
75 :
76 79994 : if (tt == TYPE_msk && rt == newBatType(TYPE_oid)) {
77 0 : tt = TYPE_oid;
78 0 : unmask = 1;
79 : }
80 79994 : bn = COLnew(0, tt, cap, TRANSIENT);
81 79984 : if (bn == NULL)
82 0 : throw(MAL, "mat.pack", SQLSTATE(HY013) MAL_MALLOC_FAIL);
83 :
84 718130 : for (i = 1; i < p->argc; i++) {
85 638166 : if (!(b = BATdescriptor(stk->stk[getArg(p, i)].val.ival))) {
86 0 : BBPreclaim(bn);
87 0 : throw(MAL, "mat.pack", SQLSTATE(HY002) RUNTIME_OBJECT_MISSING);
88 : }
89 638253 : if ((unmask && b->ttype == TYPE_msk) || mask_cand(b)) {
90 304 : BAT *ob = b;
91 304 : b = BATunmask(b);
92 304 : BBPunfix(ob->batCacheid);
93 304 : if (!b) {
94 0 : BBPreclaim(bn);
95 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
96 : }
97 : }
98 638253 : if (BATcount(bn) == 0) {
99 81697 : BAThseqbase(bn, b->hseqbase);
100 81608 : BATtseqbase(bn, b->tseqbase);
101 : }
102 638108 : if (BATappend(bn, b, NULL, false) != GDK_SUCCEED) {
103 0 : BBPreclaim(bn);
104 0 : BBPunfix(b->batCacheid);
105 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
106 : }
107 637859 : BBPunfix(b->batCacheid);
108 : }
109 79964 : if (bn->tnil && bn->tnonil) {
110 0 : BBPreclaim(bn);
111 0 : throw(MAL, "mat.pack",
112 : "INTERNAL ERROR" "bn->tnil or bn->tnonil fails ");
113 : }
114 79964 : *ret = bn->batCacheid;
115 79964 : BBPkeepref(bn);
116 79964 : return MAL_SUCCEED;
117 : }
118 :
119 : /*
120 : * Enable incremental packing. The SQL front-end requires
121 : * fixed oid sequences.
122 : */
123 : static str
124 1418371 : MATpackIncrement(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr p)
125 : {
126 1418371 : bat *ret = getArgReference_bat(stk, p, 0);
127 1418371 : int pieces;
128 1418371 : BAT *b, *bb, *bn;
129 1418371 : size_t newsize;
130 :
131 1418371 : (void) cntxt;
132 1418371 : b = BATdescriptor(stk->stk[getArg(p, 1)].val.ival);
133 1422660 : if (b == NULL)
134 0 : throw(MAL, "mat.pack", SQLSTATE(HY002) RUNTIME_OBJECT_MISSING);
135 :
136 1422660 : if (getArgType(mb, p, 2) == TYPE_int) {
137 : /* first step, estimate with some slack */
138 192286 : pieces = stk->stk[getArg(p, 2)].val.ival;
139 192286 : int tt = ATOMtype(b->ttype);
140 192286 : if (b->ttype == TYPE_msk)
141 0 : tt = TYPE_oid;
142 192286 : bn = COLnew(b->hseqbase, tt, (BUN) (1.2 * BATcount(b) * pieces),
143 : TRANSIENT);
144 192069 : if (bn == NULL) {
145 0 : BBPunfix(b->batCacheid);
146 0 : throw(MAL, "mat.pack", SQLSTATE(HY013) MAL_MALLOC_FAIL);
147 : }
148 : /* allocate enough space for the vheap, but not for strings,
149 : * since BATappend does clever things for strings, and not for
150 : * vheap views since they may well get shared */
151 192069 : if (b->tvheap && b->tvheap->parentid == b->batCacheid && bn->tvheap
152 54366 : && ATOMstorage(b->ttype) != TYPE_str) {
153 48 : newsize = b->tvheap->size * pieces;
154 48 : if (HEAPextend(bn->tvheap, newsize, true) != GDK_SUCCEED) {
155 0 : BBPunfix(b->batCacheid);
156 0 : BBPreclaim(bn);
157 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
158 : }
159 : }
160 192069 : BATtseqbase(bn, b->tseqbase);
161 191491 : if (b->ttype == TYPE_msk || mask_cand(b)) {
162 0 : BAT *ob = b;
163 0 : b = BATunmask(b);
164 0 : BBPunfix(ob->batCacheid);
165 0 : if (!b) {
166 0 : BBPreclaim(bn);
167 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
168 : }
169 : }
170 191491 : if (BATappend(bn, b, NULL, false) != GDK_SUCCEED) {
171 0 : BBPreclaim(bn);
172 0 : BBPunfix(b->batCacheid);
173 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
174 : }
175 191098 : bn->tunique_est = b->tunique_est;
176 191098 : bn->unused = (pieces - 1); /* misuse "unused" field */
177 191098 : BBPunfix(b->batCacheid);
178 191952 : if (bn->tnil && bn->tnonil) {
179 0 : BBPreclaim(bn);
180 0 : throw(MAL, "mat.pack",
181 0 : "INTERNAL ERROR" " bn->tnil %d bn->tnonil %d", bn->tnil,
182 0 : bn->tnonil);
183 : }
184 191952 : *ret = bn->batCacheid;
185 191952 : BBPretain(bn->batCacheid);
186 192283 : BBPunfix(bn->batCacheid);
187 : } else {
188 : /* remaining steps */
189 1230374 : if (!(bb = BATdescriptor(stk->stk[getArg(p, 2)].val.ival))) {
190 0 : BBPunfix(b->batCacheid);
191 0 : throw(MAL, "mat.pack", SQLSTATE(HY002) RUNTIME_OBJECT_MISSING);
192 : }
193 1230177 : if (bb->ttype == TYPE_msk || mask_cand(bb)) {
194 0 : BAT *obb = bb;
195 0 : bb = BATunmask(bb);
196 0 : BBPunfix(obb->batCacheid);
197 0 : if (!bb) {
198 0 : BBPunfix(b->batCacheid);
199 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
200 : }
201 : }
202 1230177 : if (BATcount(b) == 0) {
203 693376 : BAThseqbase(b, bb->hseqbase);
204 692148 : BATtseqbase(b, bb->tseqbase);
205 : }
206 1228914 : if (BATappend(b, bb, NULL, false) != GDK_SUCCEED) {
207 0 : BBPunfix(bb->batCacheid);
208 0 : BBPunfix(b->batCacheid);
209 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
210 : }
211 1222403 : BBPunfix(bb->batCacheid);
212 1228164 : b->tunique_est += bb->tunique_est;
213 1228164 : b->unused--;
214 1228164 : if (b->unused == 0 && (b = BATsetaccess(b, BAT_READ)) == NULL)
215 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
216 1228541 : if (b->tnil && b->tnonil) {
217 0 : BBPunfix(b->batCacheid);
218 0 : throw(MAL, "mat.pack",
219 : "INTERNAL ERROR" " b->tnil or b->tnonil fails ");
220 : }
221 1228541 : *ret = b->batCacheid;
222 1228541 : BBPretain(b->batCacheid);
223 1228868 : BBPunfix(b->batCacheid);
224 : }
225 : return MAL_SUCCEED;
226 : }
227 :
228 : static str
229 79943 : MATpack(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr p)
230 : {
231 79943 : return MATpackInternal(cntxt, mb, stk, p);
232 : }
233 :
234 : static str
235 285810 : MATpackValues(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr p)
236 : {
237 285810 : int i, type, first = 1;
238 285810 : bat *ret;
239 285810 : BAT *bn;
240 :
241 285810 : (void) cntxt;
242 285810 : type = getArgType(mb, p, first);
243 285810 : bn = COLnew(0, type, p->argc, TRANSIENT);
244 316658 : if (bn == NULL)
245 0 : throw(MAL, "mat.pack", SQLSTATE(HY013) MAL_MALLOC_FAIL);
246 :
247 316658 : if (ATOMextern(type)) {
248 995460 : for (i = first; i < p->argc; i++)
249 807710 : if (BUNappend(bn, stk->stk[getArg(p, i)].val.pval, false) != GDK_SUCCEED)
250 0 : goto bailout;
251 : } else {
252 689947 : for (i = first; i < p->argc; i++)
253 561390 : if (BUNappend(bn, getArgReference(stk, p, i), false) != GDK_SUCCEED)
254 0 : goto bailout;
255 : }
256 316307 : ret = getArgReference_bat(stk, p, 0);
257 316307 : *ret = bn->batCacheid;
258 316307 : BBPkeepref(bn);
259 316307 : return MAL_SUCCEED;
260 0 : bailout:
261 0 : BBPreclaim(bn);
262 0 : throw(MAL, "mat.pack", GDK_EXCEPTION);
263 : }
264 :
265 : #include "mel.h"
266 : mel_func mat_init_funcs[] = {
267 : pattern("mat", "new", MATpack, false, "Define a Merge Association Table (MAT). Fall back to the pack operation\nwhen this is called ", args(1,2, batargany("",1),batvarargany("b",1))),
268 : pattern("bat", "pack", MATpackValues, false, "Materialize the values into a BAT. Avoiding a clash with mat.pack() in mergetable", args(1,2, batargany("",1),varargany("",1))),
269 : pattern("mat", "pack", MATpackValues, false, "Materialize the MAT (of values) into a BAT", args(1,2, batargany("",1),varargany("",1))),
270 : pattern("mat", "pack", MATpack, false, "Materialize the MAT into a BAT", args(1,2, batargany("",1),batvarargany("b",1))),
271 : pattern("mat", "packIncrement", MATpackIncrement, false, "Prepare incremental mat pack", args(1,3, batargany("",1),batargany("b",1),arg("pieces",int))),
272 : pattern("mat", "packIncrement", MATpackIncrement, false, "Prepare incremental mat pack", args(1,3, batargany("",1),batargany("b",1),batargany("c",1))),
273 : { .imp=NULL }
274 : };
275 : #include "mal_import.h"
276 : #ifdef _MSC_VER
277 : #undef read
278 : #pragma section(".CRT$XCU",read)
279 : #endif
280 323 : LIB_STARTUP_FUNC(init_mat_mal)
281 323 : { mal_module("mat", NULL, mat_init_funcs); }
|
