Class LeafAggregator

class LeafAggregator

Public 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)