thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 09:32:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Renamed NumbersMtBlockInputStream to NumbersMultiThreadedBlockInputStream.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-08-20 17:13:06 +03:00
parent eecc8b0121
commit 7bd748c969
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/Storages/System/StorageSystemNumbers.cpp
View File

@ -51,10 +51,10 @@ struct NumbersMtState
using NumbersMtStatePtr = std::shared_ptr<NumbersMtState>; using NumbersMtStatePtr = std::shared_ptr<NumbersMtState>;
class NumbersMtBlockInputStream : public IBlockInputStream class NumbersMultiThreadedBlockInputStream : public IBlockInputStream
{ {
public: 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_) {} : state(std::move(state_)), counter(state->counter), block_size(block_size_), max_counter(max_counter_) {}
String getName() const override { return "NumbersMt"; } String getName() const override { return "NumbersMt"; }
@ -131,7 +131,7 @@ BlockInputStreams StorageSystemNumbers::read(
UInt64 max_counter = offset + *limit; UInt64 max_counter = offset + *limit;
for (size_t i = 0; i < num_streams; ++i) 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; return res;
} }