OmniSciDB  a5dc49c757
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Public Member Functions | List of all members
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, const bool is_update_delete)
 
void leafCatalogConsistencyCheck (const Catalog_Namespace::SessionInfo &parent_session_info)
 
std::map< size_t, 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 checkpointLeafShardsWithAutoRollback (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 > 		getLeafTableEpochs (const Catalog_Namespace::SessionInfo &parent_session_info, const int32_t db_id, const int32_t table_id)
 
void setLeafTableEpochs (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)
 
void set_cur_session (const TSessionId parent_session, const std::string &start_time_str, const std::string &label)
 
void invalidate_cur_session (const TSessionId parent_session, const std::string &start_time_str, const std::string &label)
 
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()); }
CHECK
#define CHECK(condition)
Definition: Logger.h:291

Member Function Documentation

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

Definition at line 74 of file LeafAggregator.h.

References CHECK.

77  {
78  CHECK(false);
79  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::clear_leaf_cpu_memory ( const TSessionId  session)
inline

Definition at line 154 of file LeafAggregator.h.

References CHECK.

154 { CHECK(false); }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::clear_leaf_gpu_memory ( const TSessionId  session)
inline

Definition at line 156 of file LeafAggregator.h.

References CHECK.

156 { CHECK(false); }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::clone_session ( const TSessionId  session1,
const TSessionId  session2 
)
inline

Definition at line 123 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::clone_session().

123  {
124  CHECK(false);
125  };
CHECK
#define CHECK(condition)
Definition: Logger.h:291

+ 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 110 of file LeafAggregator.h.

References CHECK.

113  {
114  CHECK(false);
115  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::disconnect ( const TSessionId  session)
inline

Definition at line 117 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::disconnect_impl().

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

+ 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,
const bool  is_update_delete 
)
inline

Definition at line 40 of file LeafAggregator.h.

References CHECK.

Referenced by heavydb.cursor.Cursor::executemany().

43  {
44  CHECK(false);
45  return {nullptr, {}};
46  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291

+ Here is the caller graph for this function:

TQueryResult LeafAggregator::forwardQueryToLeaf ( const Catalog_Namespace::SessionInfo &  parent_session_info,
const std::string &  query_str,
const size_t  leaf_idx 
)
inline

Definition at line 60 of file LeafAggregator.h.

References CHECK.

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

Definition at line 53 of file LeafAggregator.h.

References CHECK.

55  {
56  CHECK(false);
57  return {};
58  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
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 81 of file LeafAggregator.h.

References CHECK.

83  {
84  CHECK(false);
85  return 0;
86  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
TClusterHardwareInfo LeafAggregator::getHardwareInfo ( TSessionId  session)
inline

Definition at line 149 of file LeafAggregator.h.

References CHECK.

149  {
150  CHECK(false);
151  return {};
152  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
std::vector<TNodeMemoryInfo> LeafAggregator::getLeafMemoryInfo ( TSessionId  session,
Data_Namespace::MemoryLevel  memory_level 
)
inline

Definition at line 142 of file LeafAggregator.h.

References CHECK.

144  {
145  CHECK(false);
146  return {};
147  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
std::vector<TServerStatus> LeafAggregator::getLeafStatus ( TSessionId  session)
inline

Definition at line 137 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::get_status().

137  {
138  CHECK(false);
139  return {};
140  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291

+ Here is the caller graph for this function:

std::vector<Catalog_Namespace::TableEpochInfo> LeafAggregator::getLeafTableEpochs ( const Catalog_Namespace::SessionInfo &  parent_session_info,
const int32_t  db_id,
const int32_t  table_id 
)
inline

Definition at line 95 of file LeafAggregator.h.

References CHECK.

98  {
99  CHECK(false);
100  return {};
101  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::insertDataToLeaf ( const Catalog_Namespace::SessionInfo &  parent_session_info,
const size_t  leaf_idx,
const TInsertData &  thrift_insert_data 
)
inline

Definition at line 68 of file LeafAggregator.h.

References CHECK.

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

Definition at line 127 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::interrupt().

127  {
128  CHECK(false);
129  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291

+ Here is the caller graph for this function:

void LeafAggregator::invalidate_cur_session ( const TSessionId  parent_session,
const std::string &  start_time_str,
const std::string &  label 
)
inline

Definition at line 164 of file LeafAggregator.h.

References CHECK.

166  {
167  CHECK(false);
168  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::leafCatalogConsistencyCheck ( const Catalog_Namespace::SessionInfo &  parent_session_info)
inline

Definition at line 48 of file LeafAggregator.h.

References CHECK.

49  {
50  CHECK(false);
51  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
size_t LeafAggregator::leafCount ( ) const
inline

Definition at line 135 of file LeafAggregator.h.

Referenced by DBHandler::clone_session(), DBHandler::disconnect_impl(), DBHandler::get_status(), DBHandler::getServerRole(), DBHandler::interrupt(), DBHandler::interruptQuery(), DBHandler::isAggregator(), DBHandler::prepare_loader_generic(), DBHandler::set_table_epochs(), DBHandler::sql_execute(), DBHandler::sql_execute_impl(), and DBHandler::switch_database().

135 { return 0; }

+ Here is the caller graph for this function:

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 170 of file LeafAggregator.h.

References CHECK.

172  {
173  CHECK(false);
174  return {};
175  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::set_cur_session ( const TSessionId  parent_session,
const std::string &  start_time_str,
const std::string &  label 
)
inline

Definition at line 158 of file LeafAggregator.h.

References CHECK.

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

Definition at line 131 of file LeafAggregator.h.

References CHECK.

131  {
132  CHECK(false);
133  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
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 88 of file LeafAggregator.h.

References CHECK.

91  {
92  CHECK(false);
93  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::setLeafTableEpochs ( const Catalog_Namespace::SessionInfo &  parent_session_info,
const int32_t  db_id,
const std::vector< Catalog_Namespace::TableEpochInfo > &  table_epochs 
)
inline

Definition at line 103 of file LeafAggregator.h.

References CHECK.

106  {
107  CHECK(false);
108  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291
void LeafAggregator::switch_database ( const TSessionId  session,
const std::string &  dbname 
)
inline

Definition at line 119 of file LeafAggregator.h.

References CHECK.

Referenced by DBHandler::switch_database().

119  {
120  CHECK(false);
121  }
CHECK
#define CHECK(condition)
Definition: Logger.h:291

+ Here is the caller graph for this function:

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