Struct Parser::LocalConnector

struct LocalConnector : public Parser::DistributedConnector

Public Functions

~LocalConnector()

size_t getOuterFragmentCount(QueryStateProxy query_state_proxy, std::string &sql_query_string)

AggregatedResult query(QueryStateProxy query_state_proxy, std::string &sql_query_string, std::vector<size_t> outer_frag_indices, bool validate_only, bool allow_interrupt)

std::vector<AggregatedResult> query(QueryStateProxy query_state_proxy, std::string &sql_query_string, std::vector<size_t> outer_frag_indices, bool allow_interrupt)

size_t leafCount()

void insertChunksToLeaf(const Catalog_Namespace::SessionInfo &session, const size_t leaf_idx, const Fragmenter_Namespace::InsertChunks &insert_chunks)

void insertDataToLeaf(const Catalog_Namespace::SessionInfo &session, const size_t leaf_idx, Fragmenter_Namespace::InsertData &insert_data)

void checkpoint(const Catalog_Namespace::SessionInfo &session, int tableId)

void rollback(const Catalog_Namespace::SessionInfo &session, int tableId)

std::list<ColumnDescriptor> getColumnDescriptors(AggregatedResult &result, bool for_create)