thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 08:02:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Delete unusing files. [#CLICKHOUSE-2]

Browse Source
This commit is contained in:
Vitaliy Lyudvichenko 2017-09-05 17:16:07 +03:00 committed by alexey-milovidov
parent d55d5eca46
commit 325ceb85b5
1 changed files with 0 additions and 65 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
dbms/src/DataStreams/AddingDefaultBlockInputStream.h
View File

@ -1,65 +0,0 @@
#pragma once
#include <DataStreams/IProfilingBlockInputStream.h>
#include <Interpreters/evaluateMissingDefaults.h>
#include <Columns/ColumnConst.h>
#include <Interpreters/Context.h>
#include <Storages/ColumnDefault.h>
namespace DB
{
/** Adds missing columns to the block with default values.
* These columns are materialized (not constants).
*/
class AddingDefaultBlockInputStream : public IProfilingBlockInputStream
{
public:
AddingDefaultBlockInputStream(
BlockInputStreamPtr input_,
NamesAndTypesListPtr required_columns_,
const ColumnDefaults & column_defaults_,
const Context & context_)
: required_columns(required_columns_),
column_defaults(column_defaults_), context(context_)
{
children.push_back(input_);
}
String getName() const override { return "AddingDefault"; }
String getID() const override
{
std::stringstream res;
res << "AddingDefault(" << children.back()->getID();
for (NamesAndTypesList::const_iterator it = required_columns->begin(); it != required_columns->end(); ++it)
res << ", " << it->name << ", " << it->type->getName();
res << ")";
return res.str();
}
protected:
Block readImpl() override
{
Block res = children.back()->read();
if (!res)
return res;
/** @todo if somehow block does not contain values for implicitly-defaulted columns that are prerequisites
* for explicitly-defaulted ones, exception will be thrown during evaluating such columns
* (implicitly-defaulted columns are evaluated on the line after following one. */
evaluateMissingDefaults(res, *required_columns, column_defaults, context);
res.addDefaults(*required_columns);
return res;
}
private:
NamesAndTypesListPtr required_columns;
const ColumnDefaults column_defaults;
cosnt Context & context;
};
}