From 7bd748c96917753954979b9f78872bbb39c42bd9 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Tue, 20 Aug 2019 17:13:06 +0300
Subject: [PATCH] Renamed NumbersMtBlockInputStream to
 NumbersMultiThreadedBlockInputStream.

---
 dbms/src/Storages/System/StorageSystemNumbers.cpp | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dbms/src/Storages/System/StorageSystemNumbers.cpp b/dbms/src/Storages/System/StorageSystemNumbers.cpp
index b08e074af60..78e25e0c375 100644
--- a/dbms/src/Storages/System/StorageSystemNumbers.cpp
+++ b/dbms/src/Storages/System/StorageSystemNumbers.cpp
@@ -51,10 +51,10 @@ struct NumbersMtState
 
 using NumbersMtStatePtr = std::shared_ptr<NumbersMtState>;
 
-class NumbersMtBlockInputStream : public IBlockInputStream
+class NumbersMultiThreadedBlockInputStream : public IBlockInputStream
 {
 public:
-    NumbersMtBlockInputStream(NumbersMtStatePtr state_, UInt64 block_size_, UInt64 max_counter_)
+    NumbersMultiThreadedBlockInputStream(NumbersMtStatePtr state_, UInt64 block_size_, UInt64 max_counter_)
         : state(std::move(state_)), counter(state->counter), block_size(block_size_), max_counter(max_counter_) {}
 
     String getName() const override { return "NumbersMt"; }
@@ -131,7 +131,7 @@ BlockInputStreams StorageSystemNumbers::read(
         UInt64 max_counter = offset + *limit;
 
         for (size_t i = 0; i < num_streams; ++i)
-            res[i] = std::make_shared<NumbersMtBlockInputStream>(state, max_block_size, max_counter);
+            res[i] = std::make_shared<NumbersMultiThreadedBlockInputStream>(state, max_block_size, max_counter);
 
         return res;
     }