Try to fix build.

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>

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>

src/Processors/Sources/SinkToOutputStream.cpp

@@ -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();
-}
-
-}

src/Processors/Sources/SinkToOutputStream.h

@@ -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;
-};
-
-}