thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

more testing with chunked

Browse Source
This commit is contained in:
Yakov Olkhovskiy 2024-07-09 17:47:05 +00:00
parent 61f863c4e1
commit 9db80a6e2d
6 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
programs/benchmark/Benchmark.cpp
View File

@ -666,8 +666,8 @@ int mainEntryClickHouseBenchmark(int argc, char ** argv)
Strings hosts = options.count("host") ? options["host"].as<Strings>() : Strings({"localhost"});
String proto_send_chunked {"notchunked_optional"};
String proto_recv_chunked {"notchunked_optional"};
String proto_send_chunked {"chunked"};
String proto_recv_chunked {"chunked"};
if (options.count("proto_caps"))
{

4
src/Client/ConnectionParameters.cpp
View File

@ -107,8 +107,8 @@ ConnectionParameters::ConnectionParameters(const Poco::Util::AbstractConfigurati
}
}
proto_send_chunked = config.getString("proto_caps.send", "notchunked_optional");
proto_recv_chunked = config.getString("proto_caps.recv", "notchunked_optional");
proto_send_chunked = config.getString("proto_caps.send", "chunked");
proto_recv_chunked = config.getString("proto_caps.recv", "chunked");
quota_key = config.getString("quota_key", "");

4
src/Client/ConnectionParameters.h
View File

@ -20,8 +20,8 @@ struct ConnectionParameters
std::string default_database;
std::string user;
std::string password;
std::string proto_send_chunked = "notchunked_optional";
std::string proto_recv_chunked = "notchunked_optional";
std::string proto_send_chunked = "chunked";
std::string proto_recv_chunked = "chunked";
std::string quota_key;
SSHKey ssh_private_key;
std::string jwt;

8
src/Dictionaries/ClickHouseDictionarySource.cpp
View File

@ -236,8 +236,8 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory)
.host = host,
.user = named_collection->getAnyOrDefault<String>({"user", "username"}, "default"),
.password = named_collection->getOrDefault<String>("password", ""),
.proto_send_chunked = named_collection->getOrDefault<String>("proto_send_chunked", "notchunked_optional"),
.proto_recv_chunked = named_collection->getOrDefault<String>("proto_recv_chunked", "notchunked_optional"),
.proto_send_chunked = named_collection->getOrDefault<String>("proto_send_chunked", "chunked"),
.proto_recv_chunked = named_collection->getOrDefault<String>("proto_recv_chunked", "chunked"),
.quota_key = named_collection->getOrDefault<String>("quota_key", ""),
.db = named_collection->getAnyOrDefault<String>({"db", "database"}, default_database),
.table = named_collection->getOrDefault<String>("table", ""),
@ -262,8 +262,8 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory)
.host = host,
.user = config.getString(settings_config_prefix + ".user", "default"),
.password = config.getString(settings_config_prefix + ".password", ""),
.proto_send_chunked = config.getString(settings_config_prefix + ".proto_caps.send", "notchunked_optional"),
.proto_recv_chunked = config.getString(settings_config_prefix + ".proto_caps.recv", "notchunked_optional"),
.proto_send_chunked = config.getString(settings_config_prefix + ".proto_caps.send", "chunked"),
.proto_recv_chunked = config.getString(settings_config_prefix + ".proto_caps.recv", "chunked"),
.quota_key = config.getString(settings_config_prefix + ".quota_key", ""),
.db = config.getString(settings_config_prefix + ".db", default_database),
.table = config.getString(settings_config_prefix + ".table", ""),

4
src/Interpreters/Cluster.cpp
View File

@ -113,8 +113,8 @@ Cluster::Address::Address(
secure = ConfigHelper::getBool(config, config_prefix + ".secure", false, /* empty_as */true) ? Protocol::Secure::Enable : Protocol::Secure::Disable;
priority = Priority{config.getInt(config_prefix + ".priority", 1)};
proto_send_chunked = config.getString(config_prefix + ".proto_caps.send", "notchunked_optional");
proto_recv_chunked = config.getString(config_prefix + ".proto_caps.recv", "notchunked_optional");
proto_send_chunked = config.getString(config_prefix + ".proto_caps.send", "chunked");
proto_recv_chunked = config.getString(config_prefix + ".proto_caps.recv", "chunked");
const char * port_type = secure == Protocol::Secure::Enable ? "tcp_port_secure" : "tcp_port";
auto default_port = config.getInt(port_type, 0);

4
src/Interpreters/Cluster.h
View File

@ -114,8 +114,8 @@ public:
UInt16 port{0};
String user;
String password;
String proto_send_chunked = "notchunked_optional";
String proto_recv_chunked = "notchunked_optional";
String proto_send_chunked = "chunked";
String proto_recv_chunked = "chunked";
String quota_key;
/// For inter-server authorization