thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-29 21:20:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added ConvertColumnWithDictionaryToFullBlockInputStream.

Browse Source
This commit is contained in:
Nikolai Kochetov 2018-05-04 14:50:42 +03:00
parent 67769ef333
commit af5475b77c
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
dbms/src/DataStreams/ConvertColumnWithDictionaryToFullBlockInputStream.h
View File

@ -15,21 +15,22 @@ namespace DB
class ConvertColumnWithDictionaryToFullBlockInputStream : public IProfilingBlockInputStream
{
public:
ConvertColumnWithDictionaryToFullBlockInputStream(const BlockInputStreamPtr & input)
explicit ConvertColumnWithDictionaryToFullBlockInputStream(const BlockInputStreamPtr & input)
{
children.push_back(input);
}
String getName() const override { return "ConvertColumnWithDictionaryToFull"; }
Block getHeader() const override { return children.at(0)->getHeader(); }
Block getHeader() const override { return convert(children.at(0)->getHeader()); }
protected:
Block readImpl() override
{
Block res = children.back()->read();
Block readImpl() override { return convert(children.back()->read()); }
for (auto & column : res)
private:
Block convert(Block && block) const
{
for (auto & column : block)
{
auto * type_with_dict = typeid_cast<const DataTypeWithDictionary *>(column.type.get());
auto * col_with_dict = typeid_cast<const ColumnWithDictionary *>(column.column.get());
@ -49,7 +50,7 @@ protected:
}
}
return res;
return std::move(block);
}
};