From bc7c70f93fb05f16b9a41a1c65ba40a892e2b8dd Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Fri, 10 Sep 2021 12:03:45 +0300
Subject: [PATCH] Try to fix build.

---
 src/Interpreters/InterpreterInsertQuery.cpp   |  1 -
 src/Interpreters/executeQuery.cpp             |  1 -
 src/Processors/Sources/SinkToOutputStream.cpp | 25 -----------------
 src/Processors/Sources/SinkToOutputStream.h   | 27 -------------------
 4 files changed, 54 deletions(-)
 delete mode 100644 src/Processors/Sources/SinkToOutputStream.cpp
 delete mode 100644 src/Processors/Sources/SinkToOutputStream.h

diff --git a/src/Interpreters/InterpreterInsertQuery.cpp b/src/Interpreters/InterpreterInsertQuery.cpp
index d3896d373a3..aebf74f82b2 100644
--- a/src/Interpreters/InterpreterInsertQuery.cpp
+++ b/src/Interpreters/InterpreterInsertQuery.cpp
@@ -15,7 +15,6 @@
 #include <Parsers/ASTSelectQuery.h>
 #include <Parsers/ASTSelectWithUnionQuery.h>
 #include <Parsers/ASTTablesInSelectQuery.h>
-#include <Processors/Sources/SinkToOutputStream.h>
 #include <Processors/Sources/SourceFromInputStream.h>
 #include <Processors/Sinks/ExceptionHandlingSink.h>
 #include <Processors/Transforms/ExpressionTransform.h>
diff --git a/src/Interpreters/executeQuery.cpp b/src/Interpreters/executeQuery.cpp
index 54cae085207..a16c6163188 100644
--- a/src/Interpreters/executeQuery.cpp
+++ b/src/Interpreters/executeQuery.cpp
@@ -54,7 +54,6 @@
 #include <Processors/Transforms/LimitsCheckingTransform.h>
 #include <Processors/Transforms/MaterializingTransform.h>
 #include <Processors/Formats/IOutputFormat.h>
-#include <Processors/Sources/SinkToOutputStream.h>
 #include <Processors/Sinks/ExceptionHandlingSink.h>
 
 #include <random>
diff --git a/src/Processors/Sources/SinkToOutputStream.cpp b/src/Processors/Sources/SinkToOutputStream.cpp
deleted file mode 100644
index f8a890a0d9d..00000000000
--- a/src/Processors/Sources/SinkToOutputStream.cpp
+++ /dev/null
@@ -1,25 +0,0 @@
-#include <Processors/Sources/SinkToOutputStream.h>
-#include <DataStreams/IBlockOutputStream.h>
-
-
-namespace DB
-{
-
-SinkToOutputStream::SinkToOutputStream(BlockOutputStreamPtr stream_)
-    : SinkToStorage(stream_->getHeader())
-    , stream(std::move(stream_))
-{
-    stream->writePrefix();
-}
-
-void SinkToOutputStream::consume(Chunk chunk)
-{
-    stream->write(getPort().getHeader().cloneWithColumns(chunk.detachColumns()));
-}
-
-void SinkToOutputStream::onFinish()
-{
-    stream->writeSuffix();
-}
-
-}
diff --git a/src/Processors/Sources/SinkToOutputStream.h b/src/Processors/Sources/SinkToOutputStream.h
deleted file mode 100644
index 946a53b685e..00000000000
--- a/src/Processors/Sources/SinkToOutputStream.h
+++ /dev/null
@@ -1,27 +0,0 @@
-#pragma once
-#include <Processors/Sinks/SinkToStorage.h>
-
-namespace DB
-{
-
-class IBlockOutputStream;
-using BlockOutputStreamPtr = std::shared_ptr<IBlockOutputStream>;
-
-/// Sink which writes data to IBlockOutputStream.
-/// It's a temporary wrapper.
-class SinkToOutputStream : public SinkToStorage
-{
-public:
-    explicit SinkToOutputStream(BlockOutputStreamPtr stream);
-
-    String getName() const override { return "SinkToOutputStream"; }
-
-protected:
-    void consume(Chunk chunk) override;
-    void onFinish() override;
-
-private:
-    BlockOutputStreamPtr stream;
-};
-
-}