| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | joblistfactory.cpp | 710 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doAggProject() local
731 gbOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
739 TupleInfo ti(setTupleInfo(ct, gbOid, jobInfo, tblOid, sc, alias)); in doAggProject()
749 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in doAggProject()
1024 retOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
1160 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doAggProject() local
1180 retOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
1184 TupleInfo ti(setTupleInfo(ct, retOid, jobInfo, tblOid, sc, alias)); in doAggProject()
1210 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in doAggProject()
1654 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in parseExecutionPlan() local
[all …]
|
| H A D | jlf_common.cpp | 415 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in getTupleKey() local
416 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in getTupleKey()
424 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in getTupleKey()
463 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in getTupleKey() local
464 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in getTupleKey()
471 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in getTupleKey()
|
| H A D | expressionstep.cpp | 378 CalpontSystemCatalog::OID tblOid = joblist::tableOid(sc, jobInfo.csc); in populateColumnInfo() local
382 fTableOids.push_back(tblOid); in populateColumnInfo()
387 sc->oid(tblOid + 1 + sc->colPosition()); in populateColumnInfo()
416 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in populateColumnInfo()
441 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in populateColumnInfo()
|
| H A D | subquerytransformer.cpp | 205 CalpontSystemCatalog::OID tblOid = fVtable.tableOid(); in makeSubQueryStep() local
266 tblOid, fVtable.columns()[i].get(), alias)); in makeSubQueryStep()
471 CalpontSystemCatalog::OID tblOid = fVtable.tableOid(); in updateCorrelateInfo() local
472 TupleInfo ti(setTupleInfo(ct, sc->oid(), *fOutJobInfo, tblOid, sc, alias)); in updateCorrelateInfo()
|
| H A D | jlf_subquery.cpp | 794 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in addOrderByAndLimit() local
841 sc->oid((tblOid + 1) + sc->colPosition()); in addOrderByAndLimit()
|
| H A D | jlf_execplantojoblist.cpp | 2330 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doOuterJoinOnFilter() local
2332 … jobInfo, tblOid, sc->tableAlias(), sc->schemaName(), sc->viewName()); in doOuterJoinOnFilter()
2957 CalpontSystemCatalog::OID tblOid = tableOid(sc.get(), jobInfo.csc); in doConstantFilter() local
2962 pcs = new pColStep(sc->oid(), tblOid, ct, jobInfo); in doConstantFilter()
2964 pcs = new PseudoColStep(sc->oid(), tblOid, pc->pseudoType(), ct, jobInfo); in doConstantFilter()
3026 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc.get(), alias)); in doConstantFilter()
|
| H A D | jlf_tuplejoblist.cpp | 3874 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in associateTupleJobSteps() local
3877 SJSTEP sjs(new pColScanStep(oid, tblOid, ct, jobInfo)); in associateTupleJobSteps()
3882 TupleInfo ti(setTupleInfo(ct, oid, jobInfo, tblOid, sc, alias)); in associateTupleJobSteps()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | joblistfactory.cpp | 710 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doAggProject() local
731 gbOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
739 TupleInfo ti(setTupleInfo(ct, gbOid, jobInfo, tblOid, sc, alias)); in doAggProject()
749 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in doAggProject()
1024 retOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
1160 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doAggProject() local
1180 retOid = (tblOid + 1) + sc->colPosition(); in doAggProject()
1184 TupleInfo ti(setTupleInfo(ct, retOid, jobInfo, tblOid, sc, alias)); in doAggProject()
1210 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in doAggProject()
1654 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in parseExecutionPlan() local
[all …]
|
| H A D | jlf_common.cpp | 415 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in getTupleKey() local
416 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in getTupleKey()
424 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in getTupleKey()
463 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in getTupleKey() local
464 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in getTupleKey()
471 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in getTupleKey()
|
| H A D | expressionstep.cpp | 378 CalpontSystemCatalog::OID tblOid = joblist::tableOid(sc, jobInfo.csc); in populateColumnInfo() local
382 fTableOids.push_back(tblOid); in populateColumnInfo()
387 sc->oid(tblOid + 1 + sc->colPosition()); in populateColumnInfo()
416 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc, alias)); in populateColumnInfo()
441 ti = setTupleInfo(ct, dictOid, jobInfo, tblOid, sc, alias); in populateColumnInfo()
|
| H A D | subquerytransformer.cpp | 205 CalpontSystemCatalog::OID tblOid = fVtable.tableOid(); in makeSubQueryStep() local
266 tblOid, fVtable.columns()[i].get(), alias)); in makeSubQueryStep()
471 CalpontSystemCatalog::OID tblOid = fVtable.tableOid(); in updateCorrelateInfo() local
472 TupleInfo ti(setTupleInfo(ct, sc->oid(), *fOutJobInfo, tblOid, sc, alias)); in updateCorrelateInfo()
|
| H A D | jlf_subquery.cpp | 794 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in addOrderByAndLimit() local
841 sc->oid((tblOid + 1) + sc->colPosition()); in addOrderByAndLimit()
|
| H A D | jlf_execplantojoblist.cpp | 2330 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in doOuterJoinOnFilter() local
2332 … jobInfo, tblOid, sc->tableAlias(), sc->schemaName(), sc->viewName()); in doOuterJoinOnFilter()
2957 CalpontSystemCatalog::OID tblOid = tableOid(sc.get(), jobInfo.csc); in doConstantFilter() local
2962 pcs = new pColStep(sc->oid(), tblOid, ct, jobInfo); in doConstantFilter()
2964 pcs = new PseudoColStep(sc->oid(), tblOid, pc->pseudoType(), ct, jobInfo); in doConstantFilter()
3026 TupleInfo ti(setTupleInfo(ct, sc->oid(), jobInfo, tblOid, sc.get(), alias)); in doConstantFilter()
|
| H A D | jlf_tuplejoblist.cpp | 3874 CalpontSystemCatalog::OID tblOid = tableOid(sc, jobInfo.csc); in associateTupleJobSteps() local
3877 SJSTEP sjs(new pColScanStep(oid, tblOid, ct, jobInfo)); in associateTupleJobSteps()
3882 TupleInfo ti(setTupleInfo(ct, oid, jobInfo, tblOid, sc, alias)); in associateTupleJobSteps()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
| H A D | we_dmlcommandproc.cpp | 421 uint32_t tblOid = tableRoPair.objnum; in processSingleInsert() local
504 fRBMetaWriter->init(tblOid, tableName.table); in processSingleInsert()
694 BulkRollbackMgr::deleteMetaFile( tblOid ); in processSingleInsert()
700 TableMetaData::removeTableMetaData(tblOid); in processSingleInsert()
724 BulkRollbackMgr::deleteMetaFile( tblOid ); in processSingleInsert()
862 uint32_t tblOid = roPair.objnum; in processBatchInsert() local
1367 BulkRollbackMgr::deleteMetaFile( tblOid ); in processBatchInsert()
1444 uint32_t tblOid = roPair.objnum; in processBatchInsertBinary() local
2468 uint32_t tblOid, int txnID, in processBatchInsertHwmFlushChunks() argument
2525 tblOid, eMsg); in processBatchInsertHwmFlushChunks()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
| H A D | we_dmlcommandproc.cpp | 421 uint32_t tblOid = tableRoPair.objnum; in processSingleInsert() local
504 fRBMetaWriter->init(tblOid, tableName.table); in processSingleInsert()
694 BulkRollbackMgr::deleteMetaFile( tblOid ); in processSingleInsert()
700 TableMetaData::removeTableMetaData(tblOid); in processSingleInsert()
724 BulkRollbackMgr::deleteMetaFile( tblOid ); in processSingleInsert()
862 uint32_t tblOid = roPair.objnum; in processBatchInsert() local
1367 BulkRollbackMgr::deleteMetaFile( tblOid ); in processBatchInsert()
1444 uint32_t tblOid = roPair.objnum; in processBatchInsertBinary() local
2468 uint32_t tblOid, int txnID, in processBatchInsertHwmFlushChunks() argument
2525 tblOid, eMsg); in processBatchInsertHwmFlushChunks()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/xml/ |
| H A D | we_xmljob.cpp | 928 execplan::CalpontSystemCatalog::OID tblOid = in fillInXMLDataAsLoaded() local
930 tbl.mapOid = tblOid; in fillInXMLDataAsLoaded()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/xml/ |
| H A D | we_xmljob.cpp | 928 execplan::CalpontSystemCatalog::OID tblOid = in fillInXMLDataAsLoaded() local
930 tbl.mapOid = tblOid; in fillInXMLDataAsLoaded()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/splitter/ |
| H A D | we_sdhandler.cpp | 615 int32_t tblOid = getTableOID(fRef.fCmdArgs.getSchemaName(), in setup() local
617 fTableOId = tblOid; in setup()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/splitter/ |
| H A D | we_sdhandler.cpp | 615 int32_t tblOid = getTableOID(fRef.fCmdArgs.getSchemaName(), in setup() local
617 fTableOId = tblOid; in setup()
|