| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | tupleannexstep.cpp | 307 RGData rgDataOut; in nextBand() local
396 RGData rgDataOut; in executeNoOrderBy() local
484 RGData rgDataOut; in executeNoOrderByWithDistinct() local
490 rgDataOut.reinit(fRowGroupOut); in executeNoOrderByWithDistinct()
491 fRowGroupOut.setData(&rgDataOut); in executeNoOrderByWithDistinct()
594 rgDataOut = *i; in executeNoOrderByWithDistinct()
619 RGData rgDataOut; in executeWithOrderBy() local
727 rowgroup::RGData rgDataOut; in finalizeParallelOrderByDistinct() local
729 fRowGroupOut.setData(&rgDataOut); in finalizeParallelOrderByDistinct()
934 rowgroup::RGData rgDataOut; in finalizeParallelOrderBy() local
[all …]
|
| H A D | tuplehavingstep.cpp | 177 RGData rgDataOut; in nextBand() local
208 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in nextBand()
209 fRowGroupOut.setData(&rgDataOut); in nextBand()
245 rgDataOut.reinit(fRowGroupOut, 0); in nextBand()
246 fRowGroupOut.setData(&rgDataOut); in nextBand()
265 RGData rgDataOut; in execute() local
288 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in execute()
289 fRowGroupOut.setData(&rgDataOut); in execute()
301 fOutputDL->insert(rgDataOut); in execute()
|
| H A D | subquerystep.cpp | 213 RGData rgDataOut; in nextBand() local
221 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
227 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
234 fRowGroupDeliver.setData(&rgDataOut); in nextBand()
246 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
352 RGData rgDataOut; in execute() local
391 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in execute()
392 fRowGroupOut.setData(&rgDataOut); in execute()
430 fOutputDL->insert(rgDataOut); in execute()
|
| H A D | tupleconstantstep.cpp | 330 RGData rgDataOut; in nextBand() local
352 fRowGroupOut.setData(&rgDataOut); in nextBand()
399 RGData rgDataOut; in execute() local
424 fRowGroupOut.setData(&rgDataOut); in execute()
436 fOutputDL->insert(rgDataOut); in execute()
698 RGData rgDataOut(fRowGroupOut, 1); in run() local
699 fRowGroupOut.setData(&rgDataOut); in run()
705 fOutputDL->insert(rgDataOut); in run()
731 RGData rgDataOut; in nextBand() local
743 rgDataOut.reinit(fRowGroupOut, 1); in nextBand()
[all …]
|
| H A D | crossenginestep.cpp | 762 RGData rgDataOut; in nextBand() local
770 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
777 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
784 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
796 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
804 rgDataOut.reinit(fRowGroupDelivered, 0); in nextBand()
805 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
|
| H A D | windowfunctionstep.cpp | 210 RGData rgDataOut; in nextBand() local
218 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
222 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
229 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
241 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
248 rgDataOut.reinit(fRowGroupDelivered, 0); in nextBand()
249 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | tupleannexstep.cpp | 307 RGData rgDataOut; in nextBand() local
396 RGData rgDataOut; in executeNoOrderBy() local
484 RGData rgDataOut; in executeNoOrderByWithDistinct() local
490 rgDataOut.reinit(fRowGroupOut); in executeNoOrderByWithDistinct()
491 fRowGroupOut.setData(&rgDataOut); in executeNoOrderByWithDistinct()
594 rgDataOut = *i; in executeNoOrderByWithDistinct()
619 RGData rgDataOut; in executeWithOrderBy() local
727 rowgroup::RGData rgDataOut; in finalizeParallelOrderByDistinct() local
729 fRowGroupOut.setData(&rgDataOut); in finalizeParallelOrderByDistinct()
934 rowgroup::RGData rgDataOut; in finalizeParallelOrderBy() local
[all …]
|
| H A D | tuplehavingstep.cpp | 177 RGData rgDataOut; in nextBand() local
208 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in nextBand()
209 fRowGroupOut.setData(&rgDataOut); in nextBand()
245 rgDataOut.reinit(fRowGroupOut, 0); in nextBand()
246 fRowGroupOut.setData(&rgDataOut); in nextBand()
265 RGData rgDataOut; in execute() local
288 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in execute()
289 fRowGroupOut.setData(&rgDataOut); in execute()
301 fOutputDL->insert(rgDataOut); in execute()
|
| H A D | subquerystep.cpp | 213 RGData rgDataOut; in nextBand() local
221 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
227 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
234 fRowGroupDeliver.setData(&rgDataOut); in nextBand()
246 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
352 RGData rgDataOut; in execute() local
391 rgDataOut.reinit(fRowGroupOut, fRowGroupIn.getRowCount()); in execute()
392 fRowGroupOut.setData(&rgDataOut); in execute()
430 fOutputDL->insert(rgDataOut); in execute()
|
| H A D | tupleconstantstep.cpp | 330 RGData rgDataOut; in nextBand() local
352 fRowGroupOut.setData(&rgDataOut); in nextBand()
399 RGData rgDataOut; in execute() local
424 fRowGroupOut.setData(&rgDataOut); in execute()
436 fOutputDL->insert(rgDataOut); in execute()
698 RGData rgDataOut(fRowGroupOut, 1); in run() local
699 fRowGroupOut.setData(&rgDataOut); in run()
705 fOutputDL->insert(rgDataOut); in run()
731 RGData rgDataOut; in nextBand() local
743 rgDataOut.reinit(fRowGroupOut, 1); in nextBand()
[all …]
|
| H A D | crossenginestep.cpp | 762 RGData rgDataOut; in nextBand() local
770 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
777 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
784 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
796 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
804 rgDataOut.reinit(fRowGroupDelivered, 0); in nextBand()
805 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
|
| H A D | windowfunctionstep.cpp | 210 RGData rgDataOut; in nextBand() local
218 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
222 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
229 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
241 more = fOutputDL->next(fOutputIterator, &rgDataOut); in nextBand()
248 rgDataOut.reinit(fRowGroupDelivered, 0); in nextBand()
249 fRowGroupDelivered.setData(&rgDataOut); in nextBand()
|