OmniSciDB  a5dc49c757
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
DistributedHandler.h
Go to the documentation of this file.
1 /*
2  * Copyright 2022 HEAVY.AI, 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  HeavyDBAggHandler(DBHandler* db_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  HeavyDBLeafHandler(DBHandler* db_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 std::string& start_time_str,
72  const bool just_explain,
73  const std::vector<int64_t>& outer_fragment_indices) {
74  CHECK(false);
75  }
76 
77  void execute_query_step(TStepResult& _return,
78  const TPendingQuery& pending_query,
79  const TSubqueryId subquery_id,
80  const std::string& start_time_str) {
81  CHECK(false);
82  }
83 
84  void broadcast_serialized_rows(const TSerializedRows& serialized_rows,
85  const TRowDescriptor& row_desc,
86  const TQueryId query_id,
87  const TSubqueryId subquery_id,
88  const bool is_final_subquery_result) {
89  CHECK(false);
90  }
91 
92  void flush_queue() { CHECK(false); }
93 
94  friend class DBHandler;
95 };
int64_t query_get_outer_fragment_count(const TSessionId &session, const std::string &select_query)
HeavyDBAggHandler(DBHandler *db_handler)
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 check_table_consistency(TTableMeta &_return, const TSessionId &session, const int32_t table_id)
#define CHECK(condition)
Definition: Logger.h:291
HeavyDBLeafHandler(DBHandler *db_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)