From 572463f9c141b79c6e0e4112fa0c2f0bc0e5d8c1 Mon Sep 17 00:00:00 2001 From: comunodi Date: Wed, 13 Feb 2019 03:05:43 +0300 Subject: [PATCH] Style fix --- dbms/src/Dictionaries/RedisBlockInputStream.cpp | 6 ++++-- dbms/src/Dictionaries/RedisDictionarySource.cpp | 2 +- dbms/src/Dictionaries/RedisDictionarySource.h | 2 +- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/dbms/src/Dictionaries/RedisBlockInputStream.cpp b/dbms/src/Dictionaries/RedisBlockInputStream.cpp index 32d9abc71a8..85c92aad638 100644 --- a/dbms/src/Dictionaries/RedisBlockInputStream.cpp +++ b/dbms/src/Dictionaries/RedisBlockInputStream.cpp @@ -210,7 +210,8 @@ namespace DB while (num_rows < max_block_size) { - if (cursor == keys.size()) { + if (cursor == keys.size()) + { all_read = true; break; } @@ -227,7 +228,8 @@ namespace DB return {}; Poco::Redis::Array values = client->execute(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); if (value.isNull()) insertDefaultValue(*columns[1], *description.sample_block.getByPosition(1).column); diff --git a/dbms/src/Dictionaries/RedisDictionarySource.cpp b/dbms/src/Dictionaries/RedisDictionarySource.cpp index b4c1ac97330..7d546d39cf0 100644 --- a/dbms/src/Dictionaries/RedisDictionarySource.cpp +++ b/dbms/src/Dictionaries/RedisDictionarySource.cpp @@ -108,7 +108,7 @@ namespace DB { Poco::Redis::Array commandForKeys; commandForKeys << "KEYS" << "*"; - + Poco::Redis::Array keys = client->execute(commandForKeys); return std::make_shared(client, std::move(keys), sample_block, max_block_size); diff --git a/dbms/src/Dictionaries/RedisDictionarySource.h b/dbms/src/Dictionaries/RedisDictionarySource.h index d41e557ce24..f50a85ca10e 100644 --- a/dbms/src/Dictionaries/RedisDictionarySource.h +++ b/dbms/src/Dictionaries/RedisDictionarySource.h @@ -55,7 +55,7 @@ namespace DB BlockInputStreamPtr loadKeys(const Columns & /* key_columns */, const std::vector & /* requested_rows */) override { throw Exception{"Method loadKeys is unsupported for RedisDictionarySource", ErrorCodes::NOT_IMPLEMENTED}; - }; + } bool isModified() const override { return true; }