Class MapDLeafHandler¶

class MapDLeafHandler¶

Public Functions

~MapDLeafHandler()¶

Private Functions

MapDLeafHandler(DBHandler *mapd_handler)¶

int64_t query_get_outer_fragment_count(const TSessionId &session, const std::string &select_query)¶

void check_table_consistency(TTableMeta &_return, const TSessionId &session, const int32_t table_id)¶

void start_query(TPendingQuery &_return, const TSessionId &leaf_session, const TSessionId &parent_session, const std::string &query_ra, const std::string &start_time_str, const bool just_explain, const std::vector<int64_t> &outer_fragment_indices)¶

void execute_query_step(TStepResult &_return, const TPendingQuery &pending_query, const TSubqueryId subquery_id, const std::string &start_time_str)¶

void broadcast_serialized_rows(const TSerializedRows &serialized_rows, const TRowDescriptor &row_desc, const TQueryId query_id, const TSubqueryId subquery_id, const bool is_final_subquery_result)¶

void flush_queue()¶

Friends

friend MapDLeafHandler::DBHandler