diff --git a/be/src/format/generic_reader.cpp b/be/src/format/generic_reader.cpp deleted file mode 100644 index 11f9c19bcc7da1..00000000000000 --- a/be/src/format/generic_reader.cpp +++ /dev/null @@ -1,23 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -#include "format/generic_reader.h" - -namespace doris { -// GenericReader has no out-of-line method implementations. -// Column-filling logic lives in TableFormatReader (table_format_reader.cpp). -} // namespace doris diff --git a/be/src/runtime/collection_value.cpp b/be/src/runtime/collection_value.cpp deleted file mode 100644 index 1d501720695f38..00000000000000 --- a/be/src/runtime/collection_value.cpp +++ /dev/null @@ -1,39 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -#include "runtime/collection_value.h" - -#include - -namespace doris { - -void CollectionValue::shallow_copy(const CollectionValue* value) { - _length = value->_length; - _null_signs = value->_null_signs; - _data = value->_data; - _has_null = value->_has_null; -} - -void CollectionValue::copy_null_signs(const CollectionValue* other) { - if (other->_has_null) { - memcpy(_null_signs, other->_null_signs, other->size()); - } else { - _null_signs = nullptr; - } -} - -} // namespace doris diff --git a/be/src/runtime/collection_value.h b/be/src/runtime/collection_value.h index da916a9a1ae357..c444977d816bc1 100644 --- a/be/src/runtime/collection_value.h +++ b/be/src/runtime/collection_value.h @@ -38,9 +38,6 @@ class CollectionValue { explicit CollectionValue(uint64_t length) : _data(nullptr), _length(length), _has_null(false), _null_signs(nullptr) {} - CollectionValue(void* data, uint64_t length) - : _data(data), _length(length), _has_null(false), _null_signs(nullptr) {} - CollectionValue(void* data, uint64_t length, bool* null_signs) : _data(data), _length(length), _has_null(true), _null_signs(null_signs) {} @@ -49,21 +46,11 @@ class CollectionValue { bool is_null_at(uint64_t index) const { return this->_has_null && this->_null_signs[index]; } - uint64_t size() const { return _length; } - uint64_t length() const { return _length; } - void shallow_copy(const CollectionValue* other); - - void copy_null_signs(const CollectionValue* other); - const void* data() const { return _data; } bool has_null() const { return _has_null; } - const bool* null_signs() const { return _null_signs; } - void* mutable_data() { return _data; } - bool* mutable_null_signs() { return _null_signs; } void set_length(uint64_t length) { _length = length; } - void set_has_null(bool has_null) { _has_null = has_null; } void set_data(void* data) { _data = data; } void set_null_signs(bool* null_signs) { _null_signs = null_signs; } diff --git a/be/src/runtime/process_profile.h b/be/src/runtime/process_profile.h index 4cd27e7d686a43..9627026546f13a 100644 --- a/be/src/runtime/process_profile.h +++ b/be/src/runtime/process_profile.h @@ -32,13 +32,6 @@ class ProcessProfile { void refresh_profile(); - std::string print_process_profile() const { - auto version_ptr = _process_profile.get(); - std::stringstream ss; - version_ptr->pretty_print(&ss); - return ss.str(); - } - std::string print_process_profile_no_root() const { std::stringstream ss; std::vector profiles; diff --git a/be/src/runtime/result_queue_mgr.cpp b/be/src/runtime/result_queue_mgr.cpp index 13850cd0954707..216cf9eb5f8b62 100644 --- a/be/src/runtime/result_queue_mgr.cpp +++ b/be/src/runtime/result_queue_mgr.cpp @@ -104,16 +104,4 @@ Status ResultQueueMgr::cancel(const TUniqueId& fragment_instance_id) { return Status::OK(); } -void ResultQueueMgr::update_queue_status(const TUniqueId& fragment_instance_id, - const Status& status) { - if (status.ok()) { - return; - } - std::lock_guard l(_lock); - auto iter = _fragment_queue_map.find(fragment_instance_id); - if (iter != _fragment_queue_map.end()) { - iter->second->update_status(status); - } -} - } // namespace doris diff --git a/be/src/runtime/result_queue_mgr.h b/be/src/runtime/result_queue_mgr.h index d7e9f668981c76..b146c179e31dee 100644 --- a/be/src/runtime/result_queue_mgr.h +++ b/be/src/runtime/result_queue_mgr.h @@ -49,8 +49,6 @@ class ResultQueueMgr { Status cancel(const TUniqueId& fragment_id); - void update_queue_status(const TUniqueId& fragment_id, const Status& status); - private: std::mutex _lock; std::unordered_map _fragment_queue_map; diff --git a/be/src/runtime/runtime_state.h b/be/src/runtime/runtime_state.h index 905b1ffa611c61..1b3a5ea475ccbb 100644 --- a/be/src/runtime/runtime_state.h +++ b/be/src/runtime/runtime_state.h @@ -112,9 +112,6 @@ class RuntimeState { Status init(const TUniqueId& fragment_instance_id, const TQueryOptions& query_options, const TQueryGlobals& query_globals, ExecEnv* exec_env); - // for ut and non-query. - void set_exec_env(ExecEnv* exec_env) { _exec_env = exec_env; } - // for ut and non-query. void init_mem_trackers(const std::string& name = "ut", const TUniqueId& id = TUniqueId()); @@ -168,7 +165,6 @@ class RuntimeState { } int query_parallel_instance_num() const { return _query_options.parallel_instance; } - int max_errors() const { return _query_options.max_errors; } int execution_timeout() const { return _query_options.__isset.execution_timeout ? _query_options.execution_timeout : _query_options.query_timeout; @@ -213,7 +209,6 @@ class RuntimeState { TimezoneUtils::find_cctz_time_zone(_timezone, _timezone_obj); } const std::string& lc_time_names() const { return _lc_time_names; } - const std::string& user() const { return _user; } const TUniqueId& query_id() const { return _query_id; } const TUniqueId& fragment_instance_id() const { return _fragment_instance_id; } // should only be called in pipeline engine @@ -248,12 +243,6 @@ class RuntimeState { _query_options.enable_common_expr_pushdown; } - bool enable_common_expr_pushdown_for_inverted_index() const { - return enable_common_expr_pushdown() && - _query_options.__isset.enable_common_expr_pushdown_for_inverted_index && - _query_options.enable_common_expr_pushdown_for_inverted_index; - }; - bool mysql_row_binary_format() const { return _query_options.__isset.mysql_row_binary_format && _query_options.mysql_row_binary_format; @@ -267,12 +256,6 @@ class RuntimeState { // Appends error to the _error_log if there is space bool log_error(const std::string& error); - // Returns true if the error log has not reached _max_errors. - bool log_has_space() { - std::lock_guard l(_error_log_lock); - return _error_log.size() < _query_options.max_errors; - } - // Append all _error_log[_unreported_error_idx+] to new_errors and set // _unreported_error_idx to _errors_log.size() void get_unreported_errors(std::vector* new_errors); @@ -306,12 +289,8 @@ class RuntimeState { const std::vector& export_output_files() const { return _export_output_files; } - void add_export_output_file(const std::string& file) { _export_output_files.push_back(file); } - void set_db_name(const std::string& db_name) { _db_name = db_name; } - const std::string& db_name() { return _db_name; } - void set_wal_id(int64_t wal_id) { _wal_id = wal_id; } int64_t wal_id() const { return _wal_id; } @@ -322,8 +301,6 @@ class RuntimeState { const std::string& import_label() { return _import_label; } - const std::string& load_dir() const { return _load_dir; } - void set_load_job_id(int64_t job_id) { _load_job_id = job_id; } int64_t load_job_id() const { return _load_job_id; }