OmniSciDB  06b3bd477c
 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)
 
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 35 of file LeafAggregator.h.

Constructor & Destructor Documentation

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

Definition at line 37 of file LeafAggregator.h.

References CHECK().

37 { CHECK(leaves.empty()); }
CHECK(cgen_state)

+ Here is the call graph for this function:

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

References CHECK().

74  {
75  CHECK(false);
76  }
CHECK(cgen_state)

+ Here is the call graph for this function:

void LeafAggregator::clear_leaf_cpu_memory ( const TSessionId  session)
inline

Definition at line 136 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::clear_cpu_memory().

136 { CHECK(false); }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

void LeafAggregator::clear_leaf_gpu_memory ( const TSessionId  session)
inline

Definition at line 138 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::clear_gpu_memory().

138 { CHECK(false); }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 105 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::clone_session().

105  {
106  CHECK(false);
107  };
CHECK(cgen_state)

+ Here is the call graph for this function:

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

References CHECK().

Referenced by DBHandler::connect_impl().

95  {
96  CHECK(false);
97  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

void LeafAggregator::disconnect ( const TSessionId  session)
inline

Definition at line 99 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::disconnect_impl().

99 { CHECK(false); }
CHECK(cgen_state)

+ Here is the call graph for this function:

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

References CHECK().

41  {
42  CHECK(false);
43  return {nullptr, {}};
44  }
CHECK(cgen_state)

+ Here is the call 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 58 of file LeafAggregator.h.

References CHECK().

61  {
62  CHECK(false);
63  return {};
64  }
CHECK(cgen_state)

+ Here is the call graph for this function:

std::vector<TQueryResult> LeafAggregator::forwardQueryToLeaves ( const Catalog_Namespace::SessionInfo parent_session_info,
const std::string &  query_str 
)
inline

Definition at line 51 of file LeafAggregator.h.

References CHECK().

53  {
54  CHECK(false);
55  return {};
56  }
CHECK(cgen_state)

+ Here is the call 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 78 of file LeafAggregator.h.

References CHECK().

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

80  {
81  CHECK(false);
82  return 0;
83  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

TClusterHardwareInfo LeafAggregator::getHardwareInfo ( TSessionId  session)
inline

Definition at line 131 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::get_hardware_info().

131  {
132  CHECK(false);
133  return {};
134  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 124 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::get_memory().

126  {
127  CHECK(false);
128  return {};
129  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 119 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::get_status().

119  {
120  CHECK(false);
121  return {};
122  }
CHECK(cgen_state)

+ Here is the call graph for this function:

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

References CHECK().

68  {
69  CHECK(false);
70  }
CHECK(cgen_state)

+ Here is the call graph for this function:

void LeafAggregator::interrupt ( const TSessionId  query_session,
const TSessionId  interrupt_session 
)
inline

Definition at line 109 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::interrupt().

109  {
110  CHECK(false);
111  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 46 of file LeafAggregator.h.

References CHECK().

47  {
48  CHECK(false);
49  }
CHECK(cgen_state)

+ Here is the call 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 140 of file LeafAggregator.h.

References CHECK().

142  {
143  CHECK(false);
144  return {};
145  }
CHECK(cgen_state)

+ Here is the call graph for this function:

void LeafAggregator::set_execution_mode ( const TSessionId  session,
const TExecuteMode::type  mode 
)
inline

Definition at line 113 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::set_execution_mode().

113  {
114  CHECK(false);
115  }
CHECK(cgen_state)

+ Here is the call graph for this function:

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

References CHECK().

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

88  {
89  CHECK(false);
90  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 101 of file LeafAggregator.h.

References CHECK().

Referenced by DBHandler::switch_database().

101  {
102  CHECK(false);
103  }
CHECK(cgen_state)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:


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