Home
last modified time | relevance | path

Searched refs:RowGroup (Results 1 – 25 of 263) sorted by relevance

1234567891011

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Dtupleaggregatestep.h48 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 Dsubquerystep.h86 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 Dtupleconstantstep.h56 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 Dbatchprimitiveprocessor-jl.h203 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 Dcrossenginestep.h138 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 Dtuplehavingstep.h60 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 Dtuplehashjoin.h221 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 Dtupleunion.h60 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 Dtupleannexstep.h63 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 Dtupleaggregatestep.h48 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 Dsubquerystep.h86 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 Dtupleconstantstep.h56 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 Dbatchprimitiveprocessor-jl.h203 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 Dcrossenginestep.h138 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 Dtuplehavingstep.h60 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 Dtuplehashjoin.h221 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 Dtupleunion.h60 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 Drowaggregation.h418 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 Drowgroup.h252 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 Drowgroup.cpp1128 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 Drowaggregation.h418 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 Drowgroup.h252 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 Drowgroup.cpp1128 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 Dtuplejoiner.h105 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 Dtuplejoiner.h105 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 …]

1234567891011