diff --git a/dbms/src/Processors/Formats/IOutputFormat.h b/dbms/src/Processors/Formats/IOutputFormat.h index 55555717070..63561749a7c 100644 --- a/dbms/src/Processors/Formats/IOutputFormat.h +++ b/dbms/src/Processors/Formats/IOutputFormat.h @@ -64,8 +64,8 @@ public: void write(const Block & block) { consume(Chunk(block.getColumns(), block.rows())); } - void writePrefix() {} - void writeSuffix() { finalize(); } + void doWritePrefix() {} + void doWriteSuffix() { finalize(); } void setTotals(const Block & totals) { consume(Chunk(totals.getColumns(), totals.rows())); } void setExtremes(const Block & extremes) { consume(Chunk(extremes.getColumns(), extremes.rows())); } diff --git a/dbms/src/Processors/Formats/OutputStreamToOutputFormat.cpp b/dbms/src/Processors/Formats/OutputStreamToOutputFormat.cpp index 153972fc65d..7acf41f6cf7 100644 --- a/dbms/src/Processors/Formats/OutputStreamToOutputFormat.cpp +++ b/dbms/src/Processors/Formats/OutputStreamToOutputFormat.cpp @@ -14,8 +14,8 @@ void OutputStreamToOutputFormat::write(const Block & block) output_format->write(block); } -void OutputStreamToOutputFormat::writePrefix() { output_format->writePrefix(); } -void OutputStreamToOutputFormat::writeSuffix() { output_format->writeSuffix(); } +void OutputStreamToOutputFormat::writePrefix() { output_format->doWritePrefix(); } +void OutputStreamToOutputFormat::writeSuffix() { output_format->doWriteSuffix(); } void OutputStreamToOutputFormat::flush() { output_format->flush(); }