diff --git a/dbms/src/Storages/StorageNull.h b/dbms/src/Storages/StorageNull.h index 58308e4a3e6..b0af1d547aa 100644 --- a/dbms/src/Storages/StorageNull.h +++ b/dbms/src/Storages/StorageNull.h @@ -35,6 +35,8 @@ public: return pipes; } + bool supportProcessorsPipeline() const override { return true; } + BlockOutputStreamPtr write(const ASTPtr &, const Context &) override { return std::make_shared(getSampleBlock());