You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-07-30 19:23:07 +03:00
Add a few missing qualifiers
This commit is contained in:
@ -227,11 +227,11 @@ public:
|
|||||||
|
|
||||||
/** @brief add function columns (returned columns)
|
/** @brief add function columns (returned columns)
|
||||||
*/
|
*/
|
||||||
void addExpression(const vector<execplan::SRCP>&);
|
void addExpression(const std::vector<execplan::SRCP>&);
|
||||||
|
|
||||||
/** @brief add function join expresssion
|
/** @brief add function join expresssion
|
||||||
*/
|
*/
|
||||||
void addFcnJoinExp(const vector<execplan::SRCP>&);
|
void addFcnJoinExp(const std::vector<execplan::SRCP>&);
|
||||||
|
|
||||||
|
|
||||||
protected:
|
protected:
|
||||||
|
@ -199,7 +199,7 @@ private:
|
|||||||
std::vector<rowgroup::RGData > fRowGroupDatas;
|
std::vector<rowgroup::RGData > fRowGroupDatas;
|
||||||
std::vector<rowgroup::SP_ROWAGG_UM_t> fAggregators;
|
std::vector<rowgroup::SP_ROWAGG_UM_t> fAggregators;
|
||||||
std::vector<rowgroup::RowGroup> fRowGroupIns;
|
std::vector<rowgroup::RowGroup> fRowGroupIns;
|
||||||
vector<rowgroup::RowGroup> fRowGroupOuts;
|
std::vector<rowgroup::RowGroup> fRowGroupOuts;
|
||||||
std::vector<std::vector<rowgroup::RGData> > fRowGroupsDeliveredData;
|
std::vector<std::vector<rowgroup::RGData> > fRowGroupsDeliveredData;
|
||||||
bool fIsMultiThread;
|
bool fIsMultiThread;
|
||||||
int fInputIter; // iterator
|
int fInputIter; // iterator
|
||||||
|
@ -134,15 +134,15 @@ private:
|
|||||||
uint64_t nextFunctionIndex();
|
uint64_t nextFunctionIndex();
|
||||||
|
|
||||||
boost::shared_ptr<windowfunction::FrameBound> parseFrameBound(const execplan::WF_Boundary&,
|
boost::shared_ptr<windowfunction::FrameBound> parseFrameBound(const execplan::WF_Boundary&,
|
||||||
const map<uint64_t, uint64_t>&, const vector<execplan::SRCP>&,
|
const std::map<uint64_t, uint64_t>&, const std::vector<execplan::SRCP>&,
|
||||||
const boost::shared_ptr<ordering::EqualCompData>&, JobInfo&, bool, bool);
|
const boost::shared_ptr<ordering::EqualCompData>&, JobInfo&, bool, bool);
|
||||||
boost::shared_ptr<windowfunction::FrameBound> parseFrameBoundRows(
|
boost::shared_ptr<windowfunction::FrameBound> parseFrameBoundRows(
|
||||||
const execplan::WF_Boundary&, const map<uint64_t, uint64_t>&, JobInfo&);
|
const execplan::WF_Boundary&, const std::map<uint64_t, uint64_t>&, JobInfo&);
|
||||||
boost::shared_ptr<windowfunction::FrameBound> parseFrameBoundRange(
|
boost::shared_ptr<windowfunction::FrameBound> parseFrameBoundRange(
|
||||||
const execplan::WF_Boundary&, const map<uint64_t, uint64_t>&, const vector<execplan::SRCP>&,
|
const execplan::WF_Boundary&, const std::map<uint64_t, uint64_t>&, const std::vector<execplan::SRCP>&,
|
||||||
JobInfo&);
|
JobInfo&);
|
||||||
void updateWindowCols(execplan::ParseTree*, const map<uint64_t, uint64_t>&, JobInfo&);
|
void updateWindowCols(execplan::ParseTree*, const std::map<uint64_t, uint64_t>&, JobInfo&);
|
||||||
void updateWindowCols(execplan::ReturnedColumn*, const map<uint64_t, uint64_t>&, JobInfo&);
|
void updateWindowCols(execplan::ReturnedColumn*, const std::map<uint64_t, uint64_t>&, JobInfo&);
|
||||||
void sort(std::vector<joblist::RowPosition>::iterator, uint64_t);
|
void sort(std::vector<joblist::RowPosition>::iterator, uint64_t);
|
||||||
|
|
||||||
void formatMiniStats();
|
void formatMiniStats();
|
||||||
|
@ -58,7 +58,7 @@ extern boost::mutex bppLock;
|
|||||||
extern uint32_t highPriorityThreads, medPriorityThreads, lowPriorityThreads;
|
extern uint32_t highPriorityThreads, medPriorityThreads, lowPriorityThreads;
|
||||||
|
|
||||||
#ifdef PRIMPROC_STOPWATCH
|
#ifdef PRIMPROC_STOPWATCH
|
||||||
extern map<pthread_t, logging::StopWatch*> stopwatchMap;
|
extern std::map<pthread_t, logging::StopWatch*> stopwatchMap;
|
||||||
extern pthread_mutex_t stopwatchMapMutex;
|
extern pthread_mutex_t stopwatchMapMutex;
|
||||||
extern bool stopwatchThreadCreated;
|
extern bool stopwatchThreadCreated;
|
||||||
|
|
||||||
|
@ -102,7 +102,7 @@ private:
|
|||||||
int executeRedistributePlan();
|
int executeRedistributePlan();
|
||||||
|
|
||||||
int connectToWes(int);
|
int connectToWes(int);
|
||||||
void dumpPlanToFile(uint64_t, vector<PartitionInfo>&, int);
|
void dumpPlanToFile(uint64_t, std::vector<PartitionInfo>&, int);
|
||||||
void displayPlan();
|
void displayPlan();
|
||||||
|
|
||||||
uint32_t fAction;
|
uint32_t fAction;
|
||||||
|
@ -43,15 +43,15 @@ public:
|
|||||||
|
|
||||||
public:
|
public:
|
||||||
//..Public methods
|
//..Public methods
|
||||||
std::string getValue(const vector<string>& section) const;
|
std::string getValue(const std::vector<std::string>& section) const;
|
||||||
std::string getAttribute(const std::vector<string>& sections,
|
std::string getAttribute(const std::vector<std::string>& sections,
|
||||||
const std::string& Tag) const;
|
const std::string& Tag) const;
|
||||||
void getConfig(const std::string& section,
|
void getConfig(const std::string& section,
|
||||||
const std::string& name, std::vector<std::string>& values ) const;
|
const std::string& name, std::vector<std::string>& values ) const;
|
||||||
void getAttributeListForAllChildren(
|
void getAttributeListForAllChildren(
|
||||||
const vector<string>& sections,
|
const std::vector<std::string>& sections,
|
||||||
const string& attributeTag,
|
const std::string& attributeTag,
|
||||||
vector<string>& attributeValues);
|
std::vector<std::string>& attributeValues);
|
||||||
|
|
||||||
private:
|
private:
|
||||||
//..Private methods
|
//..Private methods
|
||||||
|
Reference in New Issue
Block a user