thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-10-09 18:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix build

Browse Source
This commit is contained in:
comunodi 2019-03-31 00:42:13 +03:00
parent 09a130372e
commit 8abffd4f60
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Dictionaries/RedisBlockInputStream.cpp
View File

@ -210,7 +210,7 @@ namespace DB
while (num_rows < max_block_size) while (num_rows < max_block_size)
{ {
if (cursor == keys.size()) if (cursor >= keys.size())
{ {
all_read = true; all_read = true;
break; break;

2
dbms/src/Dictionaries/RedisBlockInputStream.h
View File

@ -2,7 +2,7 @@
#include <Core/Block.h> #include <Core/Block.h>
#include <DataStreams/IBlockInputStream.h> #include <DataStreams/IBlockInputStream.h>
#include "ExternalResultDescription.h" #include <Core/ExternalResultDescription.h>
namespace Poco namespace Poco

6
dbms/src/Dictionaries/RedisDictionarySource.cpp
View File

@ -17,9 +17,9 @@ namespace DB
Block & sample_block, Block & sample_block,
const Context & /* context */) -> DictionarySourcePtr { const Context & /* context */) -> DictionarySourcePtr {
#if USE_POCO_REDIS #if USE_POCO_REDIS
return std::make_unique<RedisDictionarySource>(dict_struct, config, config_prefix + ".redis", sample_block); return std::make_unique<RedisDictionarySource>(dict_struct, config, config_prefix + ".redis", sample_block);
#else #else
(void)dict_struct; (void)dict_struct;
(void)config; (void)config;
(void)config_prefix; (void)config_prefix;
(void)sample_block; (void)sample_block;
@ -122,7 +122,7 @@ namespace DB
Poco::Redis::Array keys; Poco::Redis::Array keys;
for (const UInt64 id : ids) for (UInt64 id : ids)
keys << static_cast<Int64>(id); keys << static_cast<Int64>(id);
return std::make_shared<RedisBlockInputStream>(client, std::move(keys), sample_block, max_block_size); return std::make_shared<RedisBlockInputStream>(client, std::move(keys), sample_block, max_block_size);