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);