mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-10-09 10:00:54 +00:00
Style fix
This commit is contained in:
parent
f2eadcfe49
commit
572463f9c1
@ -210,7 +210,8 @@ 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;
|
||||||
}
|
}
|
||||||
@ -227,7 +228,8 @@ namespace DB
|
|||||||
return {};
|
return {};
|
||||||
|
|
||||||
Poco::Redis::Array values = client->execute<Poco::Redis::Array>(commandForValues);
|
Poco::Redis::Array values = client->execute<Poco::Redis::Array>(commandForValues);
|
||||||
for (size_t i = 0; i < num_rows; ++i) {
|
for (size_t i = 0; i < num_rows; ++i)
|
||||||
|
{
|
||||||
const Poco::Redis::RedisType::Ptr & value = *(values.begin() + i);
|
const Poco::Redis::RedisType::Ptr & value = *(values.begin() + i);
|
||||||
if (value.isNull())
|
if (value.isNull())
|
||||||
insertDefaultValue(*columns[1], *description.sample_block.getByPosition(1).column);
|
insertDefaultValue(*columns[1], *description.sample_block.getByPosition(1).column);
|
||||||
|
@ -108,7 +108,7 @@ namespace DB
|
|||||||
{
|
{
|
||||||
Poco::Redis::Array commandForKeys;
|
Poco::Redis::Array commandForKeys;
|
||||||
commandForKeys << "KEYS" << "*";
|
commandForKeys << "KEYS" << "*";
|
||||||
|
|
||||||
Poco::Redis::Array keys = client->execute<Poco::Redis::Array>(commandForKeys);
|
Poco::Redis::Array keys = client->execute<Poco::Redis::Array>(commandForKeys);
|
||||||
|
|
||||||
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);
|
||||||
|
@ -55,7 +55,7 @@ namespace DB
|
|||||||
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 unsupported for RedisDictionarySource", ErrorCodes::NOT_IMPLEMENTED};
|
throw Exception{"Method loadKeys is unsupported for RedisDictionarySource", ErrorCodes::NOT_IMPLEMENTED};
|
||||||
};
|
}
|
||||||
|
|
||||||
bool isModified() const override { return true; }
|
bool isModified() const override { return true; }
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user