Home
last modified time | relevance | path

Searched refs:projectSteps (Results 1 – 22 of 22) sorted by relevance

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Djlf_graphics.cpp50 JobStepVector projectSteps = project; in writeDotCmds() local
245 for (psi = projectSteps.begin(); psi < projectSteps.end(); psi++) in writeDotCmds()
285 for (psi = projectSteps.begin(), ctn = 0; psi != projectSteps.end(); ctn++, psi++) in writeDotCmds()
364 for (unsigned int k = ctn + 1; k < projectSteps.size(); k++) in writeDotCmds()
366 uint16_t stepidOut = projectSteps[k].get()->stepId(); in writeDotCmds()
367 JobStepAssociation projectInputSA = projectSteps[k].get()->inputAssociation(); in writeDotCmds()
H A Dbatchprimitiveprocessor-jl.cpp181 projectSteps.push_back(cc); in addProjectStep()
197 projectSteps.push_back(cc); in addProjectStep()
213 projectSteps.push_back(cc); in addProjectStep()
234 projectSteps.push_back(cc); in addProjectStep()
253 projectSteps.push_back(cc); in addProjectStep()
287 idbassert(projectCount <= projectSteps.size());
376 projectSteps[i]->setLBID(r.getRid(), 1);
882 projectSteps[i]->setLBID(baseRid, dbRoot); in setLBID()
1086 projectSteps[i]->createCommand(bs); in createBPP()
1216 projectSteps[i]->runCommand(bs); in runBPP()
[all …]
H A Djoblistfactory.cpp1637 projectSteps = doAggProject(csep, jobInfo); in parseExecutionPlan()
1641 projectSteps = doProject(jobInfo.nonConstCols, jobInfo); in parseExecutionPlan()
1702 JobStepVector::iterator jsiter = projectSteps.begin(); in parseExecutionPlan()
1703 JobStepVector::iterator jsend = projectSteps.end(); in parseExecutionPlan()
1759 associateTupleJobSteps(querySteps, projectSteps, deliverySteps, in makeVtableModeSteps()
1807 parseExecutionPlan(csep, jobInfo, querySteps, projectSteps, deliverySteps); in makeJobSteps()
1911 JobStepVector projectSteps; in makeJobList_() local
1920 stepNo = numberSteps(projectSteps, stepNo, jobInfo.traceFlags); in makeJobList_()
1939 copy(projectSteps.begin(), projectSteps.end(), oIter); in makeJobList_()
1976 jlf_graphics::writeDotCmds(dotFile, querySteps, projectSteps); in makeJobList_()
[all …]
H A Djlf_graphics.h36 const joblist::JobStepVector& projectSteps);
H A Dbatchprimitiveprocessor-jl.h196 return projectSteps; in getProjectSteps()
287 std::vector<SCommand> projectSteps; variable
H A Djlf_tuplejoblist.h121 JobStepVector& projectSteps,
H A Dsubquerytransformer.cpp147 JobStepVector projectSteps; in makeSubQueryStep() local
151 makeJobSteps(csep, *fSubJobInfo, querySteps, projectSteps, deliverySteps); in makeSubQueryStep()
153 makeUnionJobSteps(csep, *fSubJobInfo, querySteps, projectSteps, deliverySteps); in makeSubQueryStep()
H A Djlf_tuplejoblist.cpp3339 void makeNoTableJobStep(JobStepVector& querySteps, JobStepVector& projectSteps, in makeNoTableJobStep() argument
3343 projectSteps.clear(); in makeNoTableJobStep()
3356 void associateTupleJobSteps(JobStepVector& querySteps, JobStepVector& projectSteps, in associateTupleJobSteps() argument
3388 for (JobStepVector::iterator i = projectSteps.begin(); i != projectSteps.end(); ++i) in associateTupleJobSteps()
3470 makeNoTableJobStep(querySteps, projectSteps, deliverySteps, jobInfo); in associateTupleJobSteps()
3547 steps.insert(steps.end(), projectSteps.begin(), projectSteps.end()); in associateTupleJobSteps()
3928 it = projectSteps.begin(); in associateTupleJobSteps()
3929 end = projectSteps.end(); in associateTupleJobSteps()
3967 projectSteps.clear(); in associateTupleJobSteps()
H A Djlf_common.h479 JobStepVector& querySteps, JobStepVector& projectSteps,
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Djlf_graphics.cpp50 JobStepVector projectSteps = project; in writeDotCmds() local
245 for (psi = projectSteps.begin(); psi < projectSteps.end(); psi++) in writeDotCmds()
285 for (psi = projectSteps.begin(), ctn = 0; psi != projectSteps.end(); ctn++, psi++) in writeDotCmds()
364 for (unsigned int k = ctn + 1; k < projectSteps.size(); k++) in writeDotCmds()
366 uint16_t stepidOut = projectSteps[k].get()->stepId(); in writeDotCmds()
367 JobStepAssociation projectInputSA = projectSteps[k].get()->inputAssociation(); in writeDotCmds()
H A Dbatchprimitiveprocessor-jl.cpp181 projectSteps.push_back(cc); in addProjectStep()
197 projectSteps.push_back(cc); in addProjectStep()
213 projectSteps.push_back(cc); in addProjectStep()
234 projectSteps.push_back(cc); in addProjectStep()
253 projectSteps.push_back(cc); in addProjectStep()
287 idbassert(projectCount <= projectSteps.size());
376 projectSteps[i]->setLBID(r.getRid(), 1);
882 projectSteps[i]->setLBID(baseRid, dbRoot); in setLBID()
1086 projectSteps[i]->createCommand(bs); in createBPP()
1216 projectSteps[i]->runCommand(bs); in runBPP()
[all …]
H A Djoblistfactory.cpp1637 projectSteps = doAggProject(csep, jobInfo); in parseExecutionPlan()
1641 projectSteps = doProject(jobInfo.nonConstCols, jobInfo); in parseExecutionPlan()
1702 JobStepVector::iterator jsiter = projectSteps.begin(); in parseExecutionPlan()
1703 JobStepVector::iterator jsend = projectSteps.end(); in parseExecutionPlan()
1759 associateTupleJobSteps(querySteps, projectSteps, deliverySteps, in makeVtableModeSteps()
1807 parseExecutionPlan(csep, jobInfo, querySteps, projectSteps, deliverySteps); in makeJobSteps()
1911 JobStepVector projectSteps; in makeJobList_() local
1920 stepNo = numberSteps(projectSteps, stepNo, jobInfo.traceFlags); in makeJobList_()
1939 copy(projectSteps.begin(), projectSteps.end(), oIter); in makeJobList_()
1976 jlf_graphics::writeDotCmds(dotFile, querySteps, projectSteps); in makeJobList_()
[all …]
H A Djlf_graphics.h36 const joblist::JobStepVector& projectSteps);
H A Dbatchprimitiveprocessor-jl.h196 return projectSteps; in getProjectSteps()
287 std::vector<SCommand> projectSteps; variable
H A Djlf_tuplejoblist.h121 JobStepVector& projectSteps,
H A Dsubquerytransformer.cpp147 JobStepVector projectSteps; in makeSubQueryStep() local
151 makeJobSteps(csep, *fSubJobInfo, querySteps, projectSteps, deliverySteps); in makeSubQueryStep()
153 makeUnionJobSteps(csep, *fSubJobInfo, querySteps, projectSteps, deliverySteps); in makeSubQueryStep()
H A Djlf_tuplejoblist.cpp3339 void makeNoTableJobStep(JobStepVector& querySteps, JobStepVector& projectSteps, in makeNoTableJobStep() argument
3343 projectSteps.clear(); in makeNoTableJobStep()
3356 void associateTupleJobSteps(JobStepVector& querySteps, JobStepVector& projectSteps, in associateTupleJobSteps() argument
3388 for (JobStepVector::iterator i = projectSteps.begin(); i != projectSteps.end(); ++i) in associateTupleJobSteps()
3470 makeNoTableJobStep(querySteps, projectSteps, deliverySteps, jobInfo); in associateTupleJobSteps()
3547 steps.insert(steps.end(), projectSteps.begin(), projectSteps.end()); in associateTupleJobSteps()
3928 it = projectSteps.begin(); in associateTupleJobSteps()
3929 end = projectSteps.end(); in associateTupleJobSteps()
3967 projectSteps.clear(); in associateTupleJobSteps()
H A Djlf_common.h479 JobStepVector& querySteps, JobStepVector& projectSteps,
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/
H A Dbatchprimitiveprocessor.cpp446 projectSteps.resize(projectCount); in initBPP()
451 projectSteps[i] = SCommand(Command::makeCommand(bs, &type, projectSteps)); in initBPP()
547 projectSteps[i]->resetCommand(bs); in resetBPP()
1060 projectSteps[i]->prep(OT_BOTH, false); in initProcessor()
1062 projectSteps[i]->prep(OT_DATAVALUE, false); in initProcessor()
1518 projectSteps[j]->project(); in execute()
1896 oid = projectSteps[i]->getOID(); in execute()
2282 projectSteps[i]->nextLBID(); in nextLBID()
2387 bpp->projectSteps.resize(projectCount); in duplicate()
2390 bpp->projectSteps[i] = projectSteps[i]->duplicate(); in duplicate()
[all …]
H A Dbatchprimitiveprocessor.h226 std::vector<SCommand> projectSteps; variable
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/
H A Dbatchprimitiveprocessor.cpp446 projectSteps.resize(projectCount); in initBPP()
451 projectSteps[i] = SCommand(Command::makeCommand(bs, &type, projectSteps)); in initBPP()
547 projectSteps[i]->resetCommand(bs); in resetBPP()
1060 projectSteps[i]->prep(OT_BOTH, false); in initProcessor()
1062 projectSteps[i]->prep(OT_DATAVALUE, false); in initProcessor()
1518 projectSteps[j]->project(); in execute()
1896 oid = projectSteps[i]->getOID(); in execute()
2282 projectSteps[i]->nextLBID(); in nextLBID()
2387 bpp->projectSteps.resize(projectCount); in duplicate()
2390 bpp->projectSteps[i] = projectSteps[i]->duplicate(); in duplicate()
[all …]
H A Dbatchprimitiveprocessor.h226 std::vector<SCommand> projectSteps; variable