From 54eeeb7cf255970e9af4d667b689e3379b126a5d Mon Sep 17 00:00:00 2001
From: Dmitrii Kovalkov <dimas.kovas@gmail.com>
Date: Mon, 30 Aug 2021 16:58:40 +0300
Subject: [PATCH] Add compat between SinkToStorage and BlockOutputStream

---
 src/Processors/Sources/SinkToOutputStream.cpp | 2 +-
 src/Processors/Sources/SinkToOutputStream.h   | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/Processors/Sources/SinkToOutputStream.cpp b/src/Processors/Sources/SinkToOutputStream.cpp
index 7612ba10fb3..f8a890a0d9d 100644
--- a/src/Processors/Sources/SinkToOutputStream.cpp
+++ b/src/Processors/Sources/SinkToOutputStream.cpp
@@ -6,7 +6,7 @@ namespace DB
 {
 
 SinkToOutputStream::SinkToOutputStream(BlockOutputStreamPtr stream_)
-    : ISink(stream_->getHeader())
+    : SinkToStorage(stream_->getHeader())
     , stream(std::move(stream_))
 {
     stream->writePrefix();
diff --git a/src/Processors/Sources/SinkToOutputStream.h b/src/Processors/Sources/SinkToOutputStream.h
index 5362608551f..946a53b685e 100644
--- a/src/Processors/Sources/SinkToOutputStream.h
+++ b/src/Processors/Sources/SinkToOutputStream.h
@@ -1,5 +1,5 @@
 #pragma once
-#include <Processors/ISink.h>
+#include <Processors/Sinks/SinkToStorage.h>
 
 namespace DB
 {
@@ -9,7 +9,7 @@ using BlockOutputStreamPtr = std::shared_ptr<IBlockOutputStream>;
 
 /// Sink which writes data to IBlockOutputStream.
 /// It's a temporary wrapper.
-class SinkToOutputStream : public ISink
+class SinkToOutputStream : public SinkToStorage
 {
 public:
     explicit SinkToOutputStream(BlockOutputStreamPtr stream);