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)