OmniSciDB  8fa3bf436f
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
MapDLeafHandler Class Reference

#include <DistributedHandler.h>

Public Member Functions

 ~MapDLeafHandler ()
 

Private Member 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

class DBHandler
 

Detailed Description

Definition at line 48 of file DistributedHandler.h.

Constructor & Destructor Documentation

MapDLeafHandler::~MapDLeafHandler ( )
inline

Definition at line 50 of file DistributedHandler.h.

50 {}
MapDLeafHandler::MapDLeafHandler ( DBHandler mapd_handler)
inlineprivate

Definition at line 53 of file DistributedHandler.h.

References CHECK.

53 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:203

Member Function Documentation

void MapDLeafHandler::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

Definition at line 84 of file DistributedHandler.h.

References CHECK.

88  {
89  CHECK(false);
90  }
#define CHECK(condition)
Definition: Logger.h:203
void MapDLeafHandler::check_table_consistency ( TTableMeta &  _return,
const TSessionId &  session,
const int32_t  table_id 
)
inlineprivate

Definition at line 61 of file DistributedHandler.h.

References CHECK.

63  {
64  CHECK(false);
65  };
#define CHECK(condition)
Definition: Logger.h:203
void MapDLeafHandler::execute_query_step ( TStepResult &  _return,
const TPendingQuery &  pending_query,
const TSubqueryId  subquery_id,
const std::string &  start_time_str 
)
inlineprivate

Definition at line 77 of file DistributedHandler.h.

References CHECK.

80  {
81  CHECK(false);
82  }
#define CHECK(condition)
Definition: Logger.h:203
void MapDLeafHandler::flush_queue ( )
inlineprivate

Definition at line 92 of file DistributedHandler.h.

References CHECK.

92 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:203
int64_t MapDLeafHandler::query_get_outer_fragment_count ( const TSessionId &  session,
const std::string &  select_query 
)
inlineprivate

Definition at line 55 of file DistributedHandler.h.

References CHECK.

56  {
57  CHECK(false);
58  return -1;
59  };
#define CHECK(condition)
Definition: Logger.h:203
void MapDLeafHandler::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

Definition at line 67 of file DistributedHandler.h.

References CHECK.

73  {
74  CHECK(false);
75  }
#define CHECK(condition)
Definition: Logger.h:203

Friends And Related Function Documentation

friend class DBHandler
friend

Definition at line 94 of file DistributedHandler.h.


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