/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
H A D | tupleaggregatestep.h | 48 const rowgroup::RowGroup&, 49 const rowgroup::RowGroup&, 63 void setOutputRowGroup(const rowgroup::RowGroup&); 64 const rowgroup::RowGroup& getOutputRowGroup() const; 65 const rowgroup::RowGroup& getDeliveredRowGroup() const; 121 rowgroup::RowGroup fRowGroupOut; 122 rowgroup::RowGroup fRowGroupDelivered; 129 rowgroup::RowGroup fRowGroupIn; 135 rowgroup::RowGroup fRowGroupPMHJ; 224 std::vector<rowgroup::RowGroup> fRowGroupIns; [all …]
|
H A D | subquerystep.h | 86 virtual void setOutputRowGroup(const rowgroup::RowGroup& rg) in setOutputRowGroup() 94 virtual const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 120 rowgroup::RowGroup fOutputRowGroup; 173 void setOutputRowGroup(const rowgroup::RowGroup& rg); 178 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 191 const rowgroup::RowGroup& getDeliveredRowGroup() const in getDeliveredRowGroup() 207 void setFeRowGroup(const rowgroup::RowGroup& rg); 212 const rowgroup::RowGroup& getFeRowGroup() const in getFeRowGroup() 246 rowgroup::RowGroup fRowGroupIn; 247 rowgroup::RowGroup fRowGroupOut; [all …]
|
H A D | tupleconstantstep.h | 56 void setOutputRowGroup(const rowgroup::RowGroup&); 57 const rowgroup::RowGroup& getOutputRowGroup() const; 58 const rowgroup::RowGroup& getDeliveredRowGroup() const; 63 virtual void initialize(const JobInfo& jobInfo, const rowgroup::RowGroup* rgIn); 65 static SJSTEP addConstantStep(const JobInfo& jobInfo, const rowgroup::RowGroup* rg = NULL); 78 rowgroup::RowGroup fRowGroupIn; 79 rowgroup::RowGroup fRowGroupOut; 131 virtual void initialize(const JobInfo& jobInfo, const rowgroup::RowGroup* rgIn); 164 void initialize(const rowgroup::RowGroup& rgIn, const JobInfo& jobInfo);
|
H A D | batchprimitiveprocessor-jl.h | 203 void setInputRowGroup(const rowgroup::RowGroup& rg); 226 const rowgroup::RowGroup& input); 228 const rowgroup::RowGroup& output); 229 void setJoinFERG(const rowgroup::RowGroup& rg); 317 rowgroup::RowGroup inputRG, projectionRG; 322 rowgroup::RowGroup joinedRG; 324 rowgroup::RowGroup aggregateRGPM; 328 std::vector<rowgroup::RowGroup> smallSideRGs; 329 rowgroup::RowGroup largeSideRG; 344 rowgroup::RowGroup fe1Input, fe2Output; [all …]
|
H A D | crossenginestep.h | 138 void setOutputRowGroup(const rowgroup::RowGroup&); 139 const rowgroup::RowGroup& getOutputRowGroup() const; 144 const rowgroup::RowGroup& getDeliveredRowGroup() const; 151 void setFE1Input(const rowgroup::RowGroup&); 153 void setFE23Output(const rowgroup::RowGroup&); 178 rowgroup::RowGroup fRowGroupOut; 179 rowgroup::RowGroup fRowGroupDelivered; 180 rowgroup::RowGroup fRowGroupAdded; 227 rowgroup::RowGroup fRowGroupFe1; 228 rowgroup::RowGroup fRowGroupFe3;
|
H A D | tuplehavingstep.h | 60 const rowgroup::RowGroup& getOutputRowGroup() const; 61 void setOutputRowGroup(const rowgroup::RowGroup&); 66 const rowgroup::RowGroup& getDeliveredRowGroup() const; 70 void initialize(const rowgroup::RowGroup& rgIn, const JobInfo& jobInfo); 86 rowgroup::RowGroup fRowGroupIn; 87 rowgroup::RowGroup fRowGroupOut;
|
H A D | tuplehashjoin.h | 221 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 225 const rowgroup::RowGroup& getSmallRowGroup() const in getSmallRowGroup() 233 const rowgroup::RowGroup& getLargeRowGroup() const in getLargeRowGroup() 322 void setFE23Output(const rowgroup::RowGroup& rg); 442 rowgroup::RowGroup largeRG, outputRG; 443 std::vector<rowgroup::RowGroup> smallRGs; 490 rowgroup::RowGroup fe2Output; 499 rowgroup::RowGroup joinFilterRG; 526 void processFE2(rowgroup::RowGroup& input, rowgroup::RowGroup& output, rowgroup::Row& inRow, 530 … rowgroup::RowGroup& inputRG, rowgroup::RowGroup& joinOutput, rowgroup::Row& largeSideRow, [all …]
|
H A D | tupleunion.h | 60 void setInputRowGroups(const std::vector<rowgroup::RowGroup>&); 61 void setOutputRowGroup(const rowgroup::RowGroup&); 64 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 68 const rowgroup::RowGroup& getDeliveredRowGroup() const in getDeliveredRowGroup() 130 void getOutput(rowgroup::RowGroup* rg, rowgroup::Row* row, rowgroup::RGData* data); 131 void addToOutput(rowgroup::Row* r, rowgroup::RowGroup* rg, bool keepit, 146 rowgroup::RowGroup outputRG; 147 std::vector<rowgroup::RowGroup> inputRGs;
|
H A D | tupleannexstep.h | 63 const rowgroup::RowGroup& getOutputRowGroup() const; 64 void setOutputRowGroup(const rowgroup::RowGroup&); 69 const rowgroup::RowGroup& getDeliveredRowGroup() const; 73 void initialize(const rowgroup::RowGroup& rgIn, const JobInfo& jobInfo); 121 rowgroup::RowGroup fRowGroupIn; 122 rowgroup::RowGroup fRowGroupOut; 123 rowgroup::RowGroup fRowGroupDeliver;
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
H A D | tupleaggregatestep.h | 48 const rowgroup::RowGroup&, 49 const rowgroup::RowGroup&, 63 void setOutputRowGroup(const rowgroup::RowGroup&); 64 const rowgroup::RowGroup& getOutputRowGroup() const; 65 const rowgroup::RowGroup& getDeliveredRowGroup() const; 121 rowgroup::RowGroup fRowGroupOut; 122 rowgroup::RowGroup fRowGroupDelivered; 129 rowgroup::RowGroup fRowGroupIn; 135 rowgroup::RowGroup fRowGroupPMHJ; 224 std::vector<rowgroup::RowGroup> fRowGroupIns; [all …]
|
H A D | subquerystep.h | 86 virtual void setOutputRowGroup(const rowgroup::RowGroup& rg) in setOutputRowGroup() 94 virtual const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 120 rowgroup::RowGroup fOutputRowGroup; 173 void setOutputRowGroup(const rowgroup::RowGroup& rg); 178 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 191 const rowgroup::RowGroup& getDeliveredRowGroup() const in getDeliveredRowGroup() 207 void setFeRowGroup(const rowgroup::RowGroup& rg); 212 const rowgroup::RowGroup& getFeRowGroup() const in getFeRowGroup() 246 rowgroup::RowGroup fRowGroupIn; 247 rowgroup::RowGroup fRowGroupOut; [all …]
|
H A D | tupleconstantstep.h | 56 void setOutputRowGroup(const rowgroup::RowGroup&); 57 const rowgroup::RowGroup& getOutputRowGroup() const; 58 const rowgroup::RowGroup& getDeliveredRowGroup() const; 63 virtual void initialize(const JobInfo& jobInfo, const rowgroup::RowGroup* rgIn); 65 static SJSTEP addConstantStep(const JobInfo& jobInfo, const rowgroup::RowGroup* rg = NULL); 78 rowgroup::RowGroup fRowGroupIn; 79 rowgroup::RowGroup fRowGroupOut; 131 virtual void initialize(const JobInfo& jobInfo, const rowgroup::RowGroup* rgIn); 164 void initialize(const rowgroup::RowGroup& rgIn, const JobInfo& jobInfo);
|
H A D | batchprimitiveprocessor-jl.h | 203 void setInputRowGroup(const rowgroup::RowGroup& rg); 226 const rowgroup::RowGroup& input); 228 const rowgroup::RowGroup& output); 229 void setJoinFERG(const rowgroup::RowGroup& rg); 317 rowgroup::RowGroup inputRG, projectionRG; 322 rowgroup::RowGroup joinedRG; 324 rowgroup::RowGroup aggregateRGPM; 328 std::vector<rowgroup::RowGroup> smallSideRGs; 329 rowgroup::RowGroup largeSideRG; 344 rowgroup::RowGroup fe1Input, fe2Output; [all …]
|
H A D | crossenginestep.h | 138 void setOutputRowGroup(const rowgroup::RowGroup&); 139 const rowgroup::RowGroup& getOutputRowGroup() const; 144 const rowgroup::RowGroup& getDeliveredRowGroup() const; 151 void setFE1Input(const rowgroup::RowGroup&); 153 void setFE23Output(const rowgroup::RowGroup&); 178 rowgroup::RowGroup fRowGroupOut; 179 rowgroup::RowGroup fRowGroupDelivered; 180 rowgroup::RowGroup fRowGroupAdded; 227 rowgroup::RowGroup fRowGroupFe1; 228 rowgroup::RowGroup fRowGroupFe3;
|
H A D | tuplehavingstep.h | 60 const rowgroup::RowGroup& getOutputRowGroup() const; 61 void setOutputRowGroup(const rowgroup::RowGroup&); 66 const rowgroup::RowGroup& getDeliveredRowGroup() const; 70 void initialize(const rowgroup::RowGroup& rgIn, const JobInfo& jobInfo); 86 rowgroup::RowGroup fRowGroupIn; 87 rowgroup::RowGroup fRowGroupOut;
|
H A D | tuplehashjoin.h | 221 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 225 const rowgroup::RowGroup& getSmallRowGroup() const in getSmallRowGroup() 233 const rowgroup::RowGroup& getLargeRowGroup() const in getLargeRowGroup() 322 void setFE23Output(const rowgroup::RowGroup& rg); 442 rowgroup::RowGroup largeRG, outputRG; 443 std::vector<rowgroup::RowGroup> smallRGs; 490 rowgroup::RowGroup fe2Output; 499 rowgroup::RowGroup joinFilterRG; 526 void processFE2(rowgroup::RowGroup& input, rowgroup::RowGroup& output, rowgroup::Row& inRow, 530 … rowgroup::RowGroup& inputRG, rowgroup::RowGroup& joinOutput, rowgroup::Row& largeSideRow, [all …]
|
H A D | tupleunion.h | 60 void setInputRowGroups(const std::vector<rowgroup::RowGroup>&); 61 void setOutputRowGroup(const rowgroup::RowGroup&); 64 const rowgroup::RowGroup& getOutputRowGroup() const in getOutputRowGroup() 68 const rowgroup::RowGroup& getDeliveredRowGroup() const in getDeliveredRowGroup() 130 void getOutput(rowgroup::RowGroup* rg, rowgroup::Row* row, rowgroup::RGData* data); 131 void addToOutput(rowgroup::Row* r, rowgroup::RowGroup* rg, bool keepit, 146 rowgroup::RowGroup outputRG; 147 std::vector<rowgroup::RowGroup> inputRGs;
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/rowgroup/ |
H A D | rowaggregation.h | 418 virtual void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) in setInputOutput() 433 void setJoinRowGroups(std::vector<RowGroup>* pSmallSideRG, RowGroup* pLargeSideRG); 489 const RowGroup* getOutputRowGroup() const in getOutputRowGroup() 493 RowGroup* getOutputRowGroup() in getOutputRowGroup() 568 rowgroup::RowGroup fKeyRG; 712 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; 860 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; 876 RowGroup& rowGroupDist() in rowGroupDist() 880 void rowGroupDist(RowGroup& rowGroupDist) in rowGroupDist() 921 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; [all …]
|
H A D | rowgroup.h | 252 class RowGroup; variable 320 friend class RowGroup; variable 538 friend class RowGroup; variable 1261 RowGroup(); 1293 RowGroup(const RowGroup&); 1296 RowGroup& operator=(const RowGroup&); 1298 ~RowGroup(); 1392 RowGroup& operator+=(const RowGroup& rhs); 1470 RowGroup operator+(const RowGroup& lhs, const RowGroup& rhs); 1472 boost::shared_array<int> makeMapping(const RowGroup& r1, const RowGroup& r2); [all …]
|
H A D | rowgroup.cpp | 1128 RowGroup::RowGroup(uint32_t colCount, in RowGroup() function in rowgroup::RowGroup 1186 RowGroup::RowGroup(const RowGroup& r) : in RowGroup() function in rowgroup::RowGroup 1205 RowGroup& RowGroup::operator=(const RowGroup& r) in operator =() 1237 RowGroup::~RowGroup() in ~RowGroup() 1436 boost::shared_array<int> makeMapping(const RowGroup& r1, const RowGroup& r2) in makeMapping() 1498 RowGroup& RowGroup::operator+=(const RowGroup& rhs) in operator +=() 1541 RowGroup operator+(const RowGroup& lhs, const RowGroup& rhs) in operator +() 1543 RowGroup temp(lhs); in operator +() 1728 void RowGroup::append(RowGroup& rg) in append() 1753 void RowGroup::append(RowGroup& rg, uint32_t startPos) in append() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/rowgroup/ |
H A D | rowaggregation.h | 418 virtual void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) in setInputOutput() 433 void setJoinRowGroups(std::vector<RowGroup>* pSmallSideRG, RowGroup* pLargeSideRG); 489 const RowGroup* getOutputRowGroup() const in getOutputRowGroup() 493 RowGroup* getOutputRowGroup() in getOutputRowGroup() 568 rowgroup::RowGroup fKeyRG; 712 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; 860 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; 876 RowGroup& rowGroupDist() in rowGroupDist() 880 void rowGroupDist(RowGroup& rowGroupDist) in rowGroupDist() 921 void setInputOutput(const RowGroup& pRowGroupIn, RowGroup* pRowGroupOut) override; [all …]
|
H A D | rowgroup.h | 252 class RowGroup; variable 320 friend class RowGroup; variable 538 friend class RowGroup; variable 1261 RowGroup(); 1293 RowGroup(const RowGroup&); 1296 RowGroup& operator=(const RowGroup&); 1298 ~RowGroup(); 1392 RowGroup& operator+=(const RowGroup& rhs); 1470 RowGroup operator+(const RowGroup& lhs, const RowGroup& rhs); 1472 boost::shared_array<int> makeMapping(const RowGroup& r1, const RowGroup& r2); [all …]
|
H A D | rowgroup.cpp | 1128 RowGroup::RowGroup(uint32_t colCount, in RowGroup() function in rowgroup::RowGroup 1186 RowGroup::RowGroup(const RowGroup& r) : in RowGroup() function in rowgroup::RowGroup 1205 RowGroup& RowGroup::operator=(const RowGroup& r) in operator =() 1237 RowGroup::~RowGroup() in ~RowGroup() 1436 boost::shared_array<int> makeMapping(const RowGroup& r1, const RowGroup& r2) in makeMapping() 1498 RowGroup& RowGroup::operator+=(const RowGroup& rhs) in operator +=() 1541 RowGroup operator+(const RowGroup& lhs, const RowGroup& rhs) in operator +() 1543 RowGroup temp(lhs); in operator +() 1728 void RowGroup::append(RowGroup& rg) in append() 1753 void RowGroup::append(RowGroup& rg, uint32_t startPos) in append() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/joiner/ |
H A D | tuplejoiner.h | 105 const rowgroup::RowGroup *mRowGroup; 107 TypelessDataStructure(const rowgroup::RowGroup *rg, in TypelessDataStructure() 152 TypelessDataHasher(const rowgroup::RowGroup *rg, in TypelessDataHasher() 165 TypelessDataComparator(const rowgroup::RowGroup *rg, in TypelessDataComparator() 178 const rowgroup::RowGroup& smallInput, 179 const rowgroup::RowGroup& largeInput, 187 const rowgroup::RowGroup& smallInput, 188 const rowgroup::RowGroup& largeInput, 267 inline const rowgroup::RowGroup& getSmallRG() in getSmallRG() 271 inline const rowgroup::RowGroup& getLargeRG() in getLargeRG() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/joiner/ |
H A D | tuplejoiner.h | 105 const rowgroup::RowGroup *mRowGroup; 107 TypelessDataStructure(const rowgroup::RowGroup *rg, in TypelessDataStructure() 152 TypelessDataHasher(const rowgroup::RowGroup *rg, in TypelessDataHasher() 165 TypelessDataComparator(const rowgroup::RowGroup *rg, in TypelessDataComparator() 178 const rowgroup::RowGroup& smallInput, 179 const rowgroup::RowGroup& largeInput, 187 const rowgroup::RowGroup& smallInput, 188 const rowgroup::RowGroup& largeInput, 267 inline const rowgroup::RowGroup& getSmallRG() in getSmallRG() 271 inline const rowgroup::RowGroup& getLargeRG() in getLargeRG() [all …]
|