Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit 441f9d0

Browse files
committed
Reduce number of friend classes for ResultSetStorage.
Signed-off-by: ienkovich <[email protected]>
1 parent c5bdd42 commit 441f9d0

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

omniscidb/QueryEngine/ResultSetReduction.cpp

+4-4
Original file line numberDiff line numberDiff line change
@@ -912,7 +912,7 @@ ResultSet* ResultSetManager::reduce(std::vector<ResultSet*>& result_sets,
912912
for (const auto result_set : result_sets) {
913913
CHECK_EQ(row_set_mem_owner, result_set->row_set_mem_owner_);
914914
}
915-
if (first_result.query_mem_desc_.getQueryDescriptionType() ==
915+
if (first_result.getQueryMemDesc().getQueryDescriptionType() ==
916916
QueryDescriptionType::GroupByBaselineHash) {
917917
const auto total_entry_count =
918918
std::accumulate(result_sets.begin(),
@@ -922,16 +922,16 @@ ResultSet* ResultSetManager::reduce(std::vector<ResultSet*>& result_sets,
922922
return init + rs->query_mem_desc_.getEntryCount();
923923
});
924924
CHECK(total_entry_count);
925-
auto query_mem_desc = first_result.query_mem_desc_;
925+
auto query_mem_desc = first_result.getQueryMemDesc();
926926
query_mem_desc.setEntryCount(total_entry_count);
927-
rs_.reset(new ResultSet(first_result.targets_,
927+
rs_.reset(new ResultSet(first_result.getTargets(),
928928
ExecutorDeviceType::CPU,
929929
query_mem_desc,
930930
row_set_mem_owner,
931931
result_rs->data_mgr_,
932932
0,
933933
0));
934-
auto result_storage = rs_->allocateStorage(first_result.target_init_vals_);
934+
auto result_storage = rs_->allocateStorage(first_result.getInitVals());
935935
rs_->initializeStorage();
936936
switch (query_mem_desc.getEffectiveKeyWidth()) {
937937
case 4:

omniscidb/QueryEngine/ResultSetStorage.h

+1-3
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,6 @@ class ResultSetStorage {
124124
query_mem_desc_.setEntryCount(new_entry_count);
125125
}
126126

127-
private:
128127
void copyKeyColWise(const size_t entry_idx,
129128
int8_t* this_buff,
130129
const int8_t* that_buff) const;
@@ -133,6 +132,7 @@ class ResultSetStorage {
133132
bool isEmptyEntry(const size_t entry_idx) const;
134133
bool isEmptyEntryColumnar(const size_t entry_idx, const int8_t* buff) const;
135134

135+
private:
136136
void fillOneEntryRowWise(const std::vector<int64_t>& entry);
137137

138138
void fillOneEntryColWise(const std::vector<int64_t>& entry);
@@ -169,8 +169,6 @@ class ResultSetStorage {
169169
std::shared_ptr<VarlenOutputInfo> varlen_output_info_;
170170

171171
friend class ResultSet;
172-
friend class ResultSetManager;
173-
friend class ResultSetReduction;
174172
};
175173

176174
using GroupValueInfo = std::pair<int64_t*, bool>;

0 commit comments

Comments
 (0)