diff options
author | vitalyisaev <vitalyisaev@ydb.tech> | 2023-11-14 09:58:56 +0300 |
---|---|---|
committer | vitalyisaev <vitalyisaev@ydb.tech> | 2023-11-14 10:20:20 +0300 |
commit | c2b2dfd9827a400a8495e172a56343462e3ceb82 (patch) | |
tree | cd4e4f597d01bede4c82dffeb2d780d0a9046bd0 /contrib/clickhouse/src/Storages/StorageURLCluster.h | |
parent | d4ae8f119e67808cb0cf776ba6e0cf95296f2df7 (diff) | |
download | ydb-c2b2dfd9827a400a8495e172a56343462e3ceb82.tar.gz |
YQ Connector: move tests from yql to ydb (OSS)
Перенос папки с тестами на Коннектор из папки yql в папку ydb (синхронизируется с github).
Diffstat (limited to 'contrib/clickhouse/src/Storages/StorageURLCluster.h')
-rw-r--r-- | contrib/clickhouse/src/Storages/StorageURLCluster.h | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/contrib/clickhouse/src/Storages/StorageURLCluster.h b/contrib/clickhouse/src/Storages/StorageURLCluster.h new file mode 100644 index 0000000000..6d8cf044bb --- /dev/null +++ b/contrib/clickhouse/src/Storages/StorageURLCluster.h @@ -0,0 +1,54 @@ +#pragma once + +#include "clickhouse_config.h" + +#include <memory> +#include <optional> + +#include <Client/Connection.h> +#include <Interpreters/Cluster.h> +#include <Storages/IStorageCluster.h> +#include <Storages/StorageURL.h> + +namespace DB +{ + +class Context; + +class StorageURLCluster : public IStorageCluster +{ +public: + StorageURLCluster( + ContextPtr context_, + const String & cluster_name_, + const String & uri_, + const String & format_, + const String & compression_method_, + const StorageID & table_id_, + const ColumnsDescription & columns_, + const ConstraintsDescription & constraints_, + const StorageURL::Configuration & configuration_, + bool structure_argument_was_provided_); + + std::string getName() const override { return "URLCluster"; } + + NamesAndTypesList getVirtuals() const override { return virtual_columns; } + + RemoteQueryExecutor::Extension getTaskIteratorExtension(ASTPtr query, const ContextPtr & context) const override; + + bool supportsSubcolumns() const override { return true; } + + bool supportsTrivialCountOptimization() const override { return true; } + +private: + void addColumnsStructureToQuery(ASTPtr & query, const String & structure, const ContextPtr & context) override; + + String uri; + String format_name; + String compression_method; + NamesAndTypesList virtual_columns; +}; + + +} + |