OmniSciDB  f632821e96
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 bool just_explain, const std::vector< int64_t > &outer_fragment_indices)
 
void execute_query_step (TStepResult &_return, const TPendingQuery &pending_query)
 
void broadcast_serialized_rows (const TSerializedRows &serialized_rows, const TRowDescriptor &row_desc, const TQueryId query_id)
 
void flush_queue ()
 

Friends

class DBHandler
 

Detailed Description

Definition at line 48 of file DistributedHandler.h.

Constructor & Destructor Documentation

◆ ~MapDLeafHandler()

MapDLeafHandler::~MapDLeafHandler ( )
inline

Definition at line 50 of file DistributedHandler.h.

50 {}

◆ MapDLeafHandler()

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:197

Member Function Documentation

◆ broadcast_serialized_rows()

void MapDLeafHandler::broadcast_serialized_rows ( const TSerializedRows &  serialized_rows,
const TRowDescriptor &  row_desc,
const TQueryId  query_id 
)
inlineprivate

Definition at line 80 of file DistributedHandler.h.

References CHECK.

82  {
83  CHECK(false);
84  }
#define CHECK(condition)
Definition: Logger.h:197

◆ check_table_consistency()

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:197

◆ execute_query_step()

void MapDLeafHandler::execute_query_step ( TStepResult &  _return,
const TPendingQuery &  pending_query 
)
inlineprivate

Definition at line 76 of file DistributedHandler.h.

References CHECK.

76  {
77  CHECK(false);
78  }
#define CHECK(condition)
Definition: Logger.h:197

◆ flush_queue()

void MapDLeafHandler::flush_queue ( )
inlineprivate

Definition at line 86 of file DistributedHandler.h.

References CHECK.

86 { CHECK(false); }
#define CHECK(condition)
Definition: Logger.h:197

◆ query_get_outer_fragment_count()

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:197

◆ start_query()

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

Definition at line 67 of file DistributedHandler.h.

References CHECK.

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

Friends And Related Function Documentation

◆ DBHandler

friend class DBHandler
friend

Definition at line 88 of file DistributedHandler.h.


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