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

Add stubs

Browse Source
This commit is contained in:
favstovol 2019-05-30 02:01:25 +03:00
parent 3175caa1c0
commit a82f4925ec
4 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
contrib/cassandra-cmake/CMakeLists.txt Normal file
View File

1
dbms/src/Common/ErrorCodes.cpp
View File

@ -427,6 +427,7 @@ namespace ErrorCodes
extern const int BAD_TTL_EXPRESSION = 450; extern const int BAD_TTL_EXPRESSION = 450;
extern const int BAD_TTL_FILE = 451; extern const int BAD_TTL_FILE = 451;
extern const int SETTING_CONSTRAINT_VIOLATION = 452; extern const int SETTING_CONSTRAINT_VIOLATION = 452;
extern const int CASSANDRA_INTERNAL_ERROR = 453;
extern const int KEEPER_EXCEPTION = 999; extern const int KEEPER_EXCEPTION = 999;
extern const int POCO_EXCEPTION = 1000; extern const int POCO_EXCEPTION = 1000;

5
dbms/src/Dictionaries/CassandraDictionarySource.cpp
View File

@ -17,7 +17,7 @@ namespace DB
Block & sample_block, Block & sample_block,
const Context & /* context */) -> DictionarySourcePtr { const Context & /* context */) -> DictionarySourcePtr {
#if USE_CASSANDRA #if USE_CASSANDRA
return std::make_unique<CassandraDictionarySource>(dict_struct, config, config_prefix + ".cassandra", sample_block); return std::make_unique<CassandraDictionarySource>(dict_struct, config, config_prefix + ".cassandra", sample_block);
#else #else
(void)dict_struct; (void)dict_struct;
(void)config; (void)config;
@ -40,7 +40,8 @@ namespace DB
namespace DB namespace DB
{ {
namespace ErrorCodes { namespace ErrorCodes
{
extern const int UNSUPPORTED_METHOD; extern const int UNSUPPORTED_METHOD;
extern const int WRONG_PASSWORD; extern const int WRONG_PASSWORD;
} }

12
dbms/src/Dictionaries/CassandraDictionarySource.h
View File

@ -44,9 +44,15 @@ public:
DictionarySourcePtr clone() const override { return std::make_unique<CassandraDictionarySource>(*this); } DictionarySourcePtr clone() const override { return std::make_unique<CassandraDictionarySource>(*this); }
BlockInputStreamPtr loadIds(const std::vector<UInt64> & ids) override; BlockInputStreamPtr loadIds(const std::vector<UInt64> & /* ids */) override
{
throw Exception{"Method loadIds is not implemented yet", ErrorCodes::NOT_IMPLEMENTED};
}
BlockInputStreamPtr loadKeys(const Columns & key_columns, const std::vector<size_t> & requested_rows) override; BlockInputStreamPtr loadKeys(const Columns & /* key_columns */, const std::vector<size_t> & /* requested_rows */) override
{
throw Exception{"Method loadKeys is not implemented yet", ErrorCodes::NOT_IMPLEMENTED};
}
BlockInputStreamPtr loadUpdatedAll() override BlockInputStreamPtr loadUpdatedAll() override
{ {
@ -56,7 +62,7 @@ public:
std::string toString() const override; std::string toString() const override;
private: private:
static std::string toConnectionString(const std::string& host, const UInt16 port); static std::string toConnectionString(const std::string & host, const UInt16 port);
const DictionaryStructure dict_struct; const DictionaryStructure dict_struct;
const std::string host; const std::string host;