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

Merge pull request #28361 from DimasKovas/block_ouput_streams_compats

Browse Source 
Add compat between SinkToStorage and BlockOutputStream
This commit is contained in:
alexey-milovidov 2021-08-31 01:41:33 +03:00 committed by GitHub
commit c6a754289b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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);