Home
last modified time | relevance | path

Searched refs:smallSideRGs (Results 1 – 10 of 10) sorted by relevance

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/
H A Dbatchprimitiveprocessor.cpp368 deserializeVector(bs, smallSideRGs); in initBPP()
370 idbassert(smallSideRGs.size() == joinerCount); in initBPP()
384 smallSideRGs[i].setData(&smallSideRowData[i]); in initBPP()
385 smallSideRGs[i].resetRowGroup(0); in initBPP()
386 ssrdPos[i] = smallSideRGs[i].getEmptySize(); in initBPP()
391 smallSideRGs[i].initRow(&smallRow); in initBPP()
394 smallSideRGs[i].getRow(0, &smallRow); in initBPP()
771 RowGroup& smallSide = smallSideRGs[joinerNum]; in addToJoiner()
1007 smallSideRGs[i].initRow(&smallRows[i], true); in initProcessor()
2366 bpp->smallSideRGs = smallSideRGs; in duplicate()
[all …]
H A Dbatchprimitiveprocessor.h313 std::vector<rowgroup::RowGroup> smallSideRGs; variable
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/
H A Dbatchprimitiveprocessor.cpp368 deserializeVector(bs, smallSideRGs); in initBPP()
370 idbassert(smallSideRGs.size() == joinerCount); in initBPP()
384 smallSideRGs[i].setData(&smallSideRowData[i]); in initBPP()
385 smallSideRGs[i].resetRowGroup(0); in initBPP()
386 ssrdPos[i] = smallSideRGs[i].getEmptySize(); in initBPP()
391 smallSideRGs[i].initRow(&smallRow); in initBPP()
394 smallSideRGs[i].getRow(0, &smallRow); in initBPP()
771 RowGroup& smallSide = smallSideRGs[joinerNum]; in addToJoiner()
1007 smallSideRGs[i].initRow(&smallRows[i], true); in initProcessor()
2366 bpp->smallSideRGs = smallSideRGs; in duplicate()
[all …]
H A Dbatchprimitiveprocessor.h313 std::vector<rowgroup::RowGroup> smallSideRGs; variable
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dbatchprimitiveprocessor-jl.cpp1067 serializeVector<RowGroup>(bs, smallSideRGs); in createBPP()
1273 smallSideRGs.push_back(tJoiners[i]->getSmallRG()); in useJoiners()
1377 smallSideRGs[joinerNum].initRow(&r); in nextTupleJoinerMsg()
1525 RowGroup& smallSide = smallSideRGs[joinerNum]; in nextTupleJoinerMsg()
H A Dbatchprimitiveprocessor-jl.h328 std::vector<rowgroup::RowGroup> smallSideRGs; variable
H A Djlf_tuplejoblist.cpp2222 vector<RowGroup> smallSideRGs; in joinToLargeTable() local
2232 smallSideRGs.push_back(info->fRowGroup); in joinToLargeTable()
2334 thjs->configSmallSideRG(smallSideRGs, tableNames); in joinToLargeTable()
2353 thjs->addSmallSideRG(smallSideRGs, tableNames); in joinToLargeTable()
2839 vector<RowGroup> smallSideRGs; in joinTablesInOrder() local
2899 smallSideRGs.push_back(info->fRowGroup); in joinTablesInOrder()
3001 thjs->configSmallSideRG(smallSideRGs, tableNames); in joinTablesInOrder()
3020 thjs->addSmallSideRG(smallSideRGs, tableNames); in joinTablesInOrder()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dbatchprimitiveprocessor-jl.cpp1067 serializeVector<RowGroup>(bs, smallSideRGs); in createBPP()
1273 smallSideRGs.push_back(tJoiners[i]->getSmallRG()); in useJoiners()
1377 smallSideRGs[joinerNum].initRow(&r); in nextTupleJoinerMsg()
1525 RowGroup& smallSide = smallSideRGs[joinerNum]; in nextTupleJoinerMsg()
H A Dbatchprimitiveprocessor-jl.h328 std::vector<rowgroup::RowGroup> smallSideRGs; variable
H A Djlf_tuplejoblist.cpp2222 vector<RowGroup> smallSideRGs; in joinToLargeTable() local
2232 smallSideRGs.push_back(info->fRowGroup); in joinToLargeTable()
2334 thjs->configSmallSideRG(smallSideRGs, tableNames); in joinToLargeTable()
2353 thjs->addSmallSideRG(smallSideRGs, tableNames); in joinToLargeTable()
2839 vector<RowGroup> smallSideRGs; in joinTablesInOrder() local
2899 smallSideRGs.push_back(info->fRowGroup); in joinTablesInOrder()
3001 thjs->configSmallSideRG(smallSideRGs, tableNames); in joinTablesInOrder()
3020 thjs->addSmallSideRG(smallSideRGs, tableNames); in joinTablesInOrder()