Home
last modified time | relevance | path

Searched refs:fInputJobStepAssociation (Results 1 – 25 of 40) sorted by relevance

12

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dlargehashjoin.cpp544 idbassert(fInputJobStepAssociation.outSize() >= 2); in doHashJoin()
564 if (0 < fInputJobStepAssociation.status()) in doHashJoin()
738 idlsz = fInputJobStepAssociation.outSize(); in toString()
740 dl1 = fInputJobStepAssociation.outAt(0)->dataList(); in toString()
751 oss << " " << fInputJobStepAssociation.outAt(0); in toString()
753 oss << " " << fInputJobStepAssociation.outAt(1); in toString()
802 idbassert(fInputJobStepAssociation.outSize() >= 2); in doStringHashJoin()
836 if (0 < fInputJobStepAssociation.status() ) in doStringHashJoin()
1138 size_t idlsz = fInputJobStepAssociation.outSize(); in toString()
1151 oss << " " << fInputJobStepAssociation.outAt(0); in toString()
[all …]
H A Dpassthrustep.cpp236 fInputJobStepAssociation = rhs.inputAssociation(); in PassThruStep()
256 fInputJobStepAssociation = rhs.inputAssociation(); in PassThruStep()
307 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
309 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
H A Dfilterstep.cpp243 idlsz = fInputJobStepAssociation.outSize(); in toString()
249 oss << " " << fInputJobStepAssociation.outAt(0); // output will include oid in toString()
251 oss << " " << fInputJobStepAssociation.outAt(1); in toString()
H A Dsubquerystep.cpp159 fInputJobStepAssociation = s->outputAssociation(); in SubAdapterStep()
179 if (fInputJobStepAssociation.outSize() == 0) in run()
182 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
339 if (fInputJobStepAssociation.outSize() > 0) in toString()
340 oss << fInputJobStepAssociation.outAt(0); in toString()
H A Dtuplehavingstep.cpp142 if (fInputJobStepAssociation.outSize() == 0) in run()
145 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
385 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
386 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dpdictionary.cpp530 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
532 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
H A Dpcolstep.cpp1369 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1371 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
1382 AnyDataListSPtr dl = fInputJobStepAssociation.outAt(0); in addFilters()
1384 FifoDataList* fifo = fInputJobStepAssociation.outAt(0)->fifoDL(); in addFilters()
H A Djobstep.h153 fInputJobStepAssociation = inputAssociation; in inputAssociation()
157 return fInputJobStepAssociation; in inputAssociation()
467 JobStepAssociation fInputJobStepAssociation; variable
H A Dpcolscan.cpp982 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
984 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
1083 AnyDataListSPtr dl = fInputJobStepAssociation.outAt(0); in addFilters()
H A Dtupleconstantstep.cpp295 if (fInputJobStepAssociation.outSize() == 0) in run()
298 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
569 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
570 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dtupleannexstep.cpp232 if (fInputJobStepAssociation.outSize() == 0) in run()
235 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
278 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
1240 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1241 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dtupleunion.cpp308 if (++runnersDone == fInputJobStepAssociation.outSize()) in readInput()
1190 for (i = 0; i < fInputJobStepAssociation.outSize(); i++) in run()
1191 inputs.push_back(fInputJobStepAssociation.outAt(i)->rowGroupDL()); in run()
1248 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1249 oss << ((i == 0) ? " " : ", ") << fInputJobStepAssociation.outAt(i); in toString()
H A Dpdictionaryscan.cpp249 if (fInputJobStepAssociation.outSize() > 0) in run()
851 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
853 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dlargehashjoin.cpp544 idbassert(fInputJobStepAssociation.outSize() >= 2); in doHashJoin()
564 if (0 < fInputJobStepAssociation.status()) in doHashJoin()
738 idlsz = fInputJobStepAssociation.outSize(); in toString()
740 dl1 = fInputJobStepAssociation.outAt(0)->dataList(); in toString()
751 oss << " " << fInputJobStepAssociation.outAt(0); in toString()
753 oss << " " << fInputJobStepAssociation.outAt(1); in toString()
802 idbassert(fInputJobStepAssociation.outSize() >= 2); in doStringHashJoin()
836 if (0 < fInputJobStepAssociation.status() ) in doStringHashJoin()
1138 size_t idlsz = fInputJobStepAssociation.outSize(); in toString()
1151 oss << " " << fInputJobStepAssociation.outAt(0); in toString()
[all …]
H A Dpassthrustep.cpp236 fInputJobStepAssociation = rhs.inputAssociation(); in PassThruStep()
256 fInputJobStepAssociation = rhs.inputAssociation(); in PassThruStep()
307 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
309 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
H A Dfilterstep.cpp243 idlsz = fInputJobStepAssociation.outSize(); in toString()
249 oss << " " << fInputJobStepAssociation.outAt(0); // output will include oid in toString()
251 oss << " " << fInputJobStepAssociation.outAt(1); in toString()
H A Dsubquerystep.cpp159 fInputJobStepAssociation = s->outputAssociation(); in SubAdapterStep()
179 if (fInputJobStepAssociation.outSize() == 0) in run()
182 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
339 if (fInputJobStepAssociation.outSize() > 0) in toString()
340 oss << fInputJobStepAssociation.outAt(0); in toString()
H A Dtuplehavingstep.cpp142 if (fInputJobStepAssociation.outSize() == 0) in run()
145 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
385 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
386 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dpdictionary.cpp530 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
532 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
H A Dpcolstep.cpp1369 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1371 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
1382 AnyDataListSPtr dl = fInputJobStepAssociation.outAt(0); in addFilters()
1384 FifoDataList* fifo = fInputJobStepAssociation.outAt(0)->fifoDL(); in addFilters()
H A Djobstep.h153 fInputJobStepAssociation = inputAssociation; in inputAssociation()
157 return fInputJobStepAssociation; in inputAssociation()
467 JobStepAssociation fInputJobStepAssociation; variable
H A Dpcolscan.cpp982 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
984 oss << fInputJobStepAssociation.outAt(i) << ", "; in toString()
1083 AnyDataListSPtr dl = fInputJobStepAssociation.outAt(0); in addFilters()
H A Dtupleconstantstep.cpp295 if (fInputJobStepAssociation.outSize() == 0) in run()
298 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
569 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
570 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dtupleannexstep.cpp232 if (fInputJobStepAssociation.outSize() == 0) in run()
235 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
278 fInputDL = fInputJobStepAssociation.outAt(0)->rowGroupDL(); in run()
1240 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1241 oss << fInputJobStepAssociation.outAt(i); in toString()
H A Dtupleunion.cpp308 if (++runnersDone == fInputJobStepAssociation.outSize()) in readInput()
1190 for (i = 0; i < fInputJobStepAssociation.outSize(); i++) in run()
1191 inputs.push_back(fInputJobStepAssociation.outAt(i)->rowGroupDL()); in run()
1248 for (unsigned i = 0; i < fInputJobStepAssociation.outSize(); i++) in toString()
1249 oss << ((i == 0) ? " " : ", ") << fInputJobStepAssociation.outAt(i); in toString()

12