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/MergeTree/MergeTreeMetadataCache.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/MergeTree/MergeTreeMetadataCache.h')
-rw-r--r-- | contrib/clickhouse/src/Storages/MergeTree/MergeTreeMetadataCache.h | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/contrib/clickhouse/src/Storages/MergeTree/MergeTreeMetadataCache.h b/contrib/clickhouse/src/Storages/MergeTree/MergeTreeMetadataCache.h new file mode 100644 index 0000000000..f3eb567a9a --- /dev/null +++ b/contrib/clickhouse/src/Storages/MergeTree/MergeTreeMetadataCache.h @@ -0,0 +1,45 @@ +#pragma once + +#include "clickhouse_config.h" + +#if USE_ROCKSDB +#include <base/types.h> +#include <Core/Types.h> +#include <Poco/Logger.h> +#error #include <rocksdb/table.h> +#error #include <rocksdb/db.h> + +namespace DB +{ +class MergeTreeMetadataCache +{ +public: + using Status = rocksdb::Status; + + static std::unique_ptr<MergeTreeMetadataCache> create(const String & dir, size_t size); + + explicit MergeTreeMetadataCache(rocksdb::DB * rocksdb_) : rocksdb{rocksdb_} + { + assert(rocksdb); + } + + MergeTreeMetadataCache(const MergeTreeMetadataCache &) = delete; + + MergeTreeMetadataCache & operator=(const MergeTreeMetadataCache &) = delete; + + Status put(const String & key, const String & value); + Status del(const String & key); + Status get(const String & key, String & value); + void getByPrefix(const String & prefix, Strings & keys, Strings & values); + uint64_t getEstimateNumKeys() const; + + void shutdown(); +private: + std::unique_ptr<rocksdb::DB> rocksdb; + Poco::Logger * log = &Poco::Logger::get("MergeTreeMetadataCache"); +}; + +using MergeTreeMetadataCachePtr = std::shared_ptr<MergeTreeMetadataCache>; +} + +#endif |