thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 01:22:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove some unused fields

Browse Source
This commit is contained in:
alesapin 2020-10-27 15:57:55 +03:00
parent ee4e6caf70
commit f35edfb2a5
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/MergeTree/ReplicatedFetchList.cpp
View File

@ -1,10 +1,10 @@
#include <Storages/MergeTree/ReplicatedFetchList.h>
#include <Common/CurrentMetrics.h>
#include <common/getThreadId.h>
#include <Common/CurrentThread.h>
namespace DB
{
ReplicatedFetchListElement::ReplicatedFetchListElement(
const std::string & database_, const std::string & table_,
const std::string & partition_id_, const std::string & result_part_name_,
@ -26,7 +26,6 @@ ReplicatedFetchListElement::ReplicatedFetchListElement(
{
}
ReplicatedFetchInfo ReplicatedFetchListElement::getInfo() const
{
ReplicatedFetchInfo res;

18
src/Storages/MergeTree/ReplicatedFetchList.h
View File

@ -50,21 +50,22 @@ struct ReplicatedFetchListElement : private boost::noncopyable
const std::string result_part_name;
const std::string result_part_path;
std::string source_replica_path;
std::string source_replica_hostname;
UInt16 source_replica_port;
std::string interserver_scheme;
std::string uri;
const std::string source_replica_path;
const std::string source_replica_hostname;
const UInt16 source_replica_port;
const std::string interserver_scheme;
const std::string uri;
const UInt8 to_detached;
Stopwatch watch;
std::atomic<Float64> progress{};
std::atomic<bool> is_cancelled{};
/// How many bytes already read
std::atomic<UInt64> bytes_read_compressed{};
UInt64 total_size_bytes_compressed{};
/// Total bytes to read
const UInt64 total_size_bytes_compressed{};
UInt64 thread_id;
const UInt64 thread_id;
ReplicatedFetchListElement(
const std::string & database_, const std::string & table_,
@ -78,6 +79,7 @@ struct ReplicatedFetchListElement : private boost::noncopyable
using ReplicatedFetchListEntry = BackgroundProcessListEntry<ReplicatedFetchListElement, ReplicatedFetchInfo>;
/// List of currently processing replicated fetches
class ReplicatedFetchList final : public BackgroundProcessList<ReplicatedFetchListElement, ReplicatedFetchInfo>
{
private: