OmniSciDB  1dac507f6e
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
MapDDistributedHandler.h
Go to the documentation of this file.
1 /*
2  * Copyright 2017 MapD Technologies, 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 #ifndef MAPDDISTRIBUTEDHANDLER_H_
25 #define MAPDDISTRIBUTEDHANDLER_H_
26 
27 #include "../MapDHandler.h"
28 
30  public:
32 
33  private:
34  MapDAggHandler(MapDHandler* mapd_handler) { CHECK(false); }
35 
36  void cluster_execute(TQueryResult& _return,
38  const std::string& query_str,
39  const bool column_format,
40  const std::string& nonce,
41  const int32_t first_n,
42  const int32_t at_most_n,
43  const MapDParameters& mapd_parameters) {
44  CHECK(false);
45  }
46  friend class MapDHandler;
47 };
48 
50  public:
52 
53  private:
54  MapDLeafHandler(MapDHandler* mapd_handler) { CHECK(false); }
55 
56  void check_table_consistency(TTableMeta& _return,
57  const TSessionId& session,
58  const int32_t table_id) {
59  CHECK(false);
60  };
61 
62  void start_query(TPendingQuery& _return,
63  const TSessionId& session,
64  const std::string& query_ra,
65  const bool just_explain) {
66  CHECK(false);
67  }
68 
69  void execute_query_step(TStepResult& _return, const TPendingQuery& pending_query) {
70  CHECK(false);
71  }
72 
73  void broadcast_serialized_rows(const TSerializedRows& serialized_rows,
74  const TRowDescriptor& row_desc,
75  const TQueryId query_id) {
76  CHECK(false);
77  }
78 
79  void flush_queue() { CHECK(false); }
80 
81  friend class MapDHandler;
82 };
83 
84 #endif /* MAPDDISTRIBUTEDHANDLER_H_ */
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 MapDParameters &mapd_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)
CHECK(cgen_state)
MapDAggHandler(MapDHandler *mapd_handler)
MapDLeafHandler(MapDHandler *mapd_handler)
void start_query(TPendingQuery &_return, const TSessionId &session, const std::string &query_ra, const bool just_explain)
void broadcast_serialized_rows(const TSerializedRows &serialized_rows, const TRowDescriptor &row_desc, const TQueryId query_id)