diff --git a/src/Storages/WindowView/BlocksListSource.h b/src/Storages/WindowView/BlocksListSource.h deleted file mode 100644 index 66cb475bc9e..00000000000 --- a/src/Storages/WindowView/BlocksListSource.h +++ /dev/null @@ -1,38 +0,0 @@ -#pragma once - -#include - - -namespace DB -{ -using BlocksListPtr = std::shared_ptr; - -/** A stream of blocks from a shared list of blocks - */ -class BlocksListSource : public SourceWithProgress -{ -public: - BlocksListSource(const BlocksListPtr & blocks_ptr_, Block header) - : SourceWithProgress(std::move(header)) - , blocks(blocks_ptr_), it(blocks_ptr_->begin()), end(blocks_ptr_->end()) {} - - String getName() const override { return "BlocksList"; } - -protected: - Chunk generate() override - { - if (it == end) - return {}; - - Block res = *it; - ++it; - return Chunk(res.getColumns(), res.rows()); - } - -private: - BlocksListPtr blocks; - BlocksList::iterator it; - const BlocksList::iterator end; -}; - -} diff --git a/src/Storages/WindowView/StorageWindowView.cpp b/src/Storages/WindowView/StorageWindowView.cpp index 239978b07c4..a87e305d7c6 100644 --- a/src/Storages/WindowView/StorageWindowView.cpp +++ b/src/Storages/WindowView/StorageWindowView.cpp @@ -37,7 +37,6 @@ #include #include -#include #include #include #include