From 94318f290405611902523f3c1be98c7e45c111d2 Mon Sep 17 00:00:00 2001 From: Sergey Skvortsov Date: Sat, 18 Jun 2022 02:43:56 +0300 Subject: [PATCH] fix: Temporarily remove DelayedJoiningTransform --- src/Processors/Transforms/JoiningTransform.h | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/src/Processors/Transforms/JoiningTransform.h b/src/Processors/Transforms/JoiningTransform.h index 4061fdb3a3e..cd8e6e38a24 100644 --- a/src/Processors/Transforms/JoiningTransform.h +++ b/src/Processors/Transforms/JoiningTransform.h @@ -87,24 +87,6 @@ private: Block readExecute(Chunk & chunk); }; -/// Joins blocks from the left table that were accumulated by the Join itself. -/// Has single input and signle output port. -/// Input port is closed when all rows of the left table are added to the Join by JoiningTransforms. -/// There can be more than one DelayedJoiningTransform working concurrently. -class DelayedJoiningTransform : public IProcessor { -public: - DelayedJoiningTransform(Block input_header, JoinPtr join_); - - String getName() const override { return "DelayedJoiningTransform"; } - - Status prepare() override; - void work() override; - -private: - JoinPtr join; - std::unique_ptr delayed_blocks; -}; - /// Fills Join with block from right table. /// Has single input and single output port. /// Output port has empty header. It is closed when all data is inserted in join.