thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-15 02:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Temporarily remove DelayedJoiningTransform

Browse Source
This commit is contained in:
Sergey Skvortsov 2022-06-18 02:43:56 +03:00
parent d3e7cb093b
commit 94318f2904
1 changed files with 0 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/Processors/Transforms/JoiningTransform.h
View File

@ -87,24 +87,6 @@ private:
Block readExecute(Chunk & chunk); 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<IDelayedJoinedBlocksStream> delayed_blocks;
};
/// Fills Join with block from right table. /// Fills Join with block from right table.
/// Has single input and single output port. /// Has single input and single output port.
/// Output port has empty header. It is closed when all data is inserted in join. /// Output port has empty header. It is closed when all data is inserted in join.