thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-04 05:22:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add compat between SinkToStorage and BlockOutputStream

Browse Source
This commit is contained in:
Dmitrii Kovalkov 2021-08-30 16:58:40 +03:00
parent af709ab9a0
commit 54eeeb7cf2
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/Sources/SinkToOutputStream.cpp
View File

@ -6,7 +6,7 @@ namespace DB
{ {
SinkToOutputStream::SinkToOutputStream(BlockOutputStreamPtr stream_) SinkToOutputStream::SinkToOutputStream(BlockOutputStreamPtr stream_)
: ISink(stream_->getHeader()) : SinkToStorage(stream_->getHeader())
, stream(std::move(stream_)) , stream(std::move(stream_))
{ {
stream->writePrefix(); stream->writePrefix();

4
src/Processors/Sources/SinkToOutputStream.h
View File

@ -1,5 +1,5 @@
#pragma once #pragma once
#include <Processors/ISink.h> #include <Processors/Sinks/SinkToStorage.h>
namespace DB namespace DB
{ {
@ -9,7 +9,7 @@ using BlockOutputStreamPtr = std::shared_ptr<IBlockOutputStream>;
/// Sink which writes data to IBlockOutputStream. /// Sink which writes data to IBlockOutputStream.
/// It's a temporary wrapper. /// It's a temporary wrapper.
class SinkToOutputStream : public ISink class SinkToOutputStream : public SinkToStorage
{ {
public: public:
explicit SinkToOutputStream(BlockOutputStreamPtr stream); explicit SinkToOutputStream(BlockOutputStreamPtr stream);