#include #include #include #include #include namespace DB { StorageSystemOne::StorageSystemOne(const std::string & name_) : name(name_), columns{{"dummy", std::make_shared()}} { } BlockInputStreams StorageSystemOne::read( const Names & column_names, const SelectQueryInfo &, const Context &, QueryProcessingStage::Enum & processed_stage, const size_t /*max_block_size*/, const unsigned /*num_streams*/) { check(column_names); processed_stage = QueryProcessingStage::FetchColumns; Block block; ColumnWithTypeAndName col; col.name = "dummy"; col.type = std::make_shared(); col.column = DataTypeUInt8().createColumnConst(1, UInt64(0))->convertToFullColumnIfConst(); block.insert(std::move(col)); return BlockInputStreams(1, std::make_shared(block)); } }