OmniSciDB  2e3a973ef4
DistributedHandler.h
Go to the documentation of this file.
1 /*
2  * Copyright 2020 OmniSci, Inc.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 /*
18  * File: MapDDistributedHandler.h
19  * Author: Chris Root
20  *
21  * Created on Nov 6, 2017, 10:00 AM
22  */
23 
24 #pragma once
25 
26 #include "../DBHandler.h"
27 
29  public:
31 
32  private:
33  MapDAggHandler(DBHandler* mapd_handler) { CHECK(false); }
34 
35  void cluster_execute(TQueryResult& _return,
37  const std::string& query_str,
38  const bool column_format,
39  const std::string& nonce,
40  const int32_t first_n,
41  const int32_t at_most_n,
42  const SystemParameters& system_parameters) {
43  CHECK(false);
44  }
45  friend class DBHandler;
46 };
47 
49  public:
51 
52  private:
53  MapDLeafHandler(DBHandler* mapd_handler) { CHECK(false); }
54 
55  int64_t query_get_outer_fragment_count(const TSessionId& session,
56  const std::string& select_query) {
57  CHECK(false);
58  return -1;
59  };
60 
61  void check_table_consistency(TTableMeta& _return,
62  const TSessionId& session,
63  const int32_t table_id) {
64  CHECK(false);
65  };
66 
67  void start_query(TPendingQuery& _return,
68  const TSessionId& leaf_session,
69  const TSessionId& parent_session,
70  const std::string& query_ra,
71  const bool just_explain,
72  const std::vector<int64_t>& outer_fragment_indices) {
73  CHECK(false);
74  }
75 
76  void execute_query_step(TStepResult& _return, const TPendingQuery& pending_query) {
77  CHECK(false);
78  }
79 
80  void broadcast_serialized_rows(const TSerializedRows& serialized_rows,
81  const TRowDescriptor& row_desc,
82  const TQueryId query_id) {
83  CHECK(false);
84  }
85 
86  void flush_queue() { CHECK(false); }
87 
88  friend class DBHandler;
89 };
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)
MapDLeafHandler(DBHandler *mapd_handler)
void cluster_execute(TQueryResult &_return, QueryStateProxy, const std::string &query_str, const bool column_format, const std::string &nonce, const int32_t first_n, const int32_t at_most_n, const SystemParameters &system_parameters)
void check_table_consistency(TTableMeta &_return, const TSessionId &session, const int32_t table_id)
void execute_query_step(TStepResult &_return, const TPendingQuery &pending_query)
MapDAggHandler(DBHandler *mapd_handler)
#define CHECK(condition)
Definition: Logger.h:197
int64_t query_get_outer_fragment_count(const TSessionId &session, const std::string &select_query)
void broadcast_serialized_rows(const TSerializedRows &serialized_rows, const TRowDescriptor &row_desc, const TQueryId query_id)