#include #include #include namespace DB { namespace ErrorCodes { extern const int NOT_IMPLEMENTED; } void IRowOutputStream::write(const Block & block, size_t row_num) { size_t columns = block.columns(); writeRowStartDelimiter(); for (size_t i = 0; i < columns; ++i) { if (i != 0) writeFieldDelimiter(); auto & col = block.getByPosition(i); writeField(*col.column, *col.type, row_num); } writeRowEndDelimiter(); } void IRowOutputStream::writeField(const IColumn &, const IDataType &, size_t) { throw Exception("Method writeField is not implemented for output format", ErrorCodes::NOT_IMPLEMENTED); } }