OmniSciDB  467d548b97
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
LeafAggregator Class Reference

#include <LeafAggregator.h>

Public Member Functions

 LeafAggregator (const std::vector< LeafHostInfo > &leaves)
 
AggregatedResult execute (const Catalog_Namespace::SessionInfo &parent_session_info, const std::string &query_ra, const ExecutionOptions &eo)
 
void leafCatalogConsistencyCheck (const Catalog_Namespace::SessionInfo &parent_session_info)
 
std::vector< TQueryResult > forwardQueryToLeaves (const Catalog_Namespace::SessionInfo &parent_session_info, const std::string &query_str)
 
TQueryResult forwardQueryToLeaf (const Catalog_Namespace::SessionInfo &parent_session_info, const std::string &query_str, const size_t leaf_idx)
 
void insertDataToLeaf (const Catalog_Namespace::SessionInfo &parent_session_info, const size_t leaf_idx, const TInsertData &thrift_insert_data)
 
void checkpointLeaf (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const int32_t table_id)
 
int32_t get_table_epochLeaf (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const int32_t table_id)
 
void set_table_epochLeaf (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const int32_t table_id, const int32_t new_epoch)
 
std::vector
< Catalog_Namespace::TableEpochInfo
get_leaf_table_epochs (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const int32_t table_id)
 
void set_leaf_table_epochs (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const std::vector< Catalog_Namespace::TableEpochInfo > &table_epochs)
 
void connect (const Catalog_Namespace::SessionInfo &parent_session_info, const std::string &user, const std::string &passwd, const std::string &dbname)
 
void disconnect (const TSessionId session)
 
void switch_database (const TSessionId session, const std::string &dbname)
 
void clone_session (const TSessionId session1, const TSessionId session2)
 
void interrupt (const TSessionId query_session, const TSessionId interrupt_session)
 
void set_execution_mode (const TSessionId session, const TExecuteMode::type mode)
 
size_t leafCount () const
 
std::vector< TServerStatus > getLeafStatus (TSessionId session)
 
std::vector< TNodeMemoryInfo > getLeafMemoryInfo (TSessionId session, Data_Namespace::MemoryLevel memory_level)
 
TClusterHardwareInfo getHardwareInfo (TSessionId session)
 
void clear_leaf_cpu_memory (const TSessionId session)
 
void clear_leaf_gpu_memory (const TSessionId session)
 
std::vector< size_t > query_get_outer_fragment_counts (const Catalog_Namespace::SessionInfo &parent_session_info, std::string &sql_query)
 

Detailed Description

Definition at line 36 of file LeafAggregator.h.

Constructor & Destructor Documentation

LeafAggregator::LeafAggregator ( const std::vector< LeafHostInfo > &  leaves)
inline

Definition at line 38 of file LeafAggregator.h.

References CHECK.

38 { CHECK(leaves.empty()); }
#define CHECK(condition)
Definition: Logger.h:197

Member Function Documentation

void LeafAggregator::checkpointLeaf ( const Catalog_Namespace::SessionInfo parent_session_info,
const int32_t  db_id,
const int32_t  table_id 
)
inline

Definition at line 73 of file LeafAggregator.h.

References CHECK.

75  {
76  CHECK(false);
77  }
#define CHECK(condition)
Definition: Logger.h:197
void LeafAggregator::clear_leaf_cpu_memory ( const TSessionId  session)
inline

Definition at line 152 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::clear_cpu_memory().

152 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::clear_leaf_gpu_memory ( const TSessionId  session)
inline

Definition at line 154 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::clear_gpu_memory().

154 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::clone_session ( const TSessionId  session1,
const TSessionId  session2 
)
inline

Definition at line 121 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::clone_session().

121  {
122  CHECK(false);
123  };
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::connect ( const Catalog_Namespace::SessionInfo parent_session_info,
const std::string &  user,
const std::string &  passwd,
const std::string &  dbname 
)
inline

Definition at line 108 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::connect_impl().

111  {
112  CHECK(false);
113  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::disconnect ( const TSessionId  session)
inline

Definition at line 115 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::disconnect_impl().

115 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

AggregatedResult LeafAggregator::execute ( const Catalog_Namespace::SessionInfo parent_session_info,
const std::string &  query_ra,
const ExecutionOptions eo 
)
inline

Definition at line 40 of file LeafAggregator.h.

References CHECK.

42  {
43  CHECK(false);
44  return {nullptr, {}};
45  }
#define CHECK(condition)
Definition: Logger.h:197
TQueryResult LeafAggregator::forwardQueryToLeaf ( const Catalog_Namespace::SessionInfo parent_session_info,
const std::string &  query_str,
const size_t  leaf_idx 
)
inline

Definition at line 59 of file LeafAggregator.h.

References CHECK.

62  {
63  CHECK(false);
64  return {};
65  }
#define CHECK(condition)
Definition: Logger.h:197
std::vector<TQueryResult> LeafAggregator::forwardQueryToLeaves ( const Catalog_Namespace::SessionInfo parent_session_info,
const std::string &  query_str 
)
inline

Definition at line 52 of file LeafAggregator.h.

References CHECK.

54  {
55  CHECK(false);
56  return {};
57  }
#define CHECK(condition)
Definition: Logger.h:197
std::vector<Catalog_Namespace::TableEpochInfo> LeafAggregator::get_leaf_table_epochs ( const Catalog_Namespace::SessionInfo parent_session_info,
const int32_t  db_id,
const int32_t  table_id 
)
inline

Definition at line 93 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_table_epochs().

96  {
97  CHECK(false);
98  return {};
99  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

int32_t LeafAggregator::get_table_epochLeaf ( const Catalog_Namespace::SessionInfo parent_session_info,
const int32_t  db_id,
const int32_t  table_id 
)
inline

Definition at line 79 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_table_epoch(), and DBHandler::get_table_epoch_by_name().

81  {
82  CHECK(false);
83  return 0;
84  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

TClusterHardwareInfo LeafAggregator::getHardwareInfo ( TSessionId  session)
inline

Definition at line 147 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_hardware_info().

147  {
148  CHECK(false);
149  return {};
150  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

std::vector<TNodeMemoryInfo> LeafAggregator::getLeafMemoryInfo ( TSessionId  session,
Data_Namespace::MemoryLevel  memory_level 
)
inline

Definition at line 140 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_memory().

142  {
143  CHECK(false);
144  return {};
145  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

std::vector<TServerStatus> LeafAggregator::getLeafStatus ( TSessionId  session)
inline

Definition at line 135 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_status().

135  {
136  CHECK(false);
137  return {};
138  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::insertDataToLeaf ( const Catalog_Namespace::SessionInfo parent_session_info,
const size_t  leaf_idx,
const TInsertData &  thrift_insert_data 
)
inline

Definition at line 67 of file LeafAggregator.h.

References CHECK.

69  {
70  CHECK(false);
71  }
#define CHECK(condition)
Definition: Logger.h:197
void LeafAggregator::interrupt ( const TSessionId  query_session,
const TSessionId  interrupt_session 
)
inline

Definition at line 125 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::interrupt(), and DBHandler::interruptQuery().

125  {
126  CHECK(false);
127  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::leafCatalogConsistencyCheck ( const Catalog_Namespace::SessionInfo parent_session_info)
inline

Definition at line 47 of file LeafAggregator.h.

References CHECK.

48  {
49  CHECK(false);
50  }
#define CHECK(condition)
Definition: Logger.h:197
std::vector<size_t> LeafAggregator::query_get_outer_fragment_counts ( const Catalog_Namespace::SessionInfo parent_session_info,
std::string &  sql_query 
)
inline

Definition at line 156 of file LeafAggregator.h.

References CHECK.

158  {
159  CHECK(false);
160  return {};
161  }
#define CHECK(condition)
Definition: Logger.h:197
void LeafAggregator::set_execution_mode ( const TSessionId  session,
const TExecuteMode::type  mode 
)
inline

Definition at line 129 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::set_execution_mode().

129  {
130  CHECK(false);
131  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::set_leaf_table_epochs ( const Catalog_Namespace::SessionInfo parent_session_info,
const int32_t  db_id,
const std::vector< Catalog_Namespace::TableEpochInfo > &  table_epochs 
)
inline

Definition at line 101 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::set_table_epochs().

104  {
105  CHECK(false);
106  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::set_table_epochLeaf ( const Catalog_Namespace::SessionInfo parent_session_info,
const int32_t  db_id,
const int32_t  table_id,
const int32_t  new_epoch 
)
inline

Definition at line 86 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::set_table_epoch(), and DBHandler::set_table_epoch_by_name().

89  {
90  CHECK(false);
91  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:

void LeafAggregator::switch_database ( const TSessionId  session,
const std::string &  dbname 
)
inline

Definition at line 117 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::switch_database().

117  {
118  CHECK(false);
119  }
#define CHECK(condition)
Definition: Logger.h:197

+ Here is the caller graph for this function:


The documentation for this class was generated from the following file: