#include <DistributedHandler.h>
|
| HeavyDBLeafHandler (DBHandler *db_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 () |
|
Definition at line 48 of file DistributedHandler.h.
HeavyDBLeafHandler::~HeavyDBLeafHandler |
( |
| ) |
|
|
inline |
HeavyDBLeafHandler::HeavyDBLeafHandler |
( |
DBHandler * |
db_handler | ) |
|
|
inlineprivate |
void HeavyDBLeafHandler::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 |
|
) |
| |
|
inlineprivate |
void HeavyDBLeafHandler::check_table_consistency |
( |
TTableMeta & |
_return, |
|
|
const TSessionId & |
session, |
|
|
const int32_t |
table_id |
|
) |
| |
|
inlineprivate |
void HeavyDBLeafHandler::execute_query_step |
( |
TStepResult & |
_return, |
|
|
const TPendingQuery & |
pending_query, |
|
|
const TSubqueryId |
subquery_id, |
|
|
const std::string & |
start_time_str |
|
) |
| |
|
inlineprivate |
void HeavyDBLeafHandler::flush_queue |
( |
| ) |
|
|
inlineprivate |
int64_t HeavyDBLeafHandler::query_get_outer_fragment_count |
( |
const TSessionId & |
session, |
|
|
const std::string & |
select_query |
|
) |
| |
|
inlineprivate |
void HeavyDBLeafHandler::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 |
|
) |
| |
|
inlineprivate |
The documentation for this class was generated from the following file: