mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-18 20:32:43 +00:00
removed garbage
This commit is contained in:
parent
1660a4fe86
commit
3dd04e4e58
@ -657,7 +657,6 @@ IBlocksStreamPtr GraceHashJoin::getDelayedBlocks()
|
|||||||
|
|
||||||
GraceHashJoin::InMemoryJoinPtr GraceHashJoin::makeInMemoryJoin(const String & bucket_id, size_t reserve_num)
|
GraceHashJoin::InMemoryJoinPtr GraceHashJoin::makeInMemoryJoin(const String & bucket_id, size_t reserve_num)
|
||||||
{
|
{
|
||||||
LOG_INFO(log, "GreaceHashJoin\n");
|
|
||||||
return std::make_unique<HashJoin>(table_join, right_sample_block, any_take_last_row, reserve_num, bucket_id);
|
return std::make_unique<HashJoin>(table_join, right_sample_block, any_take_last_row, reserve_num, bucket_id);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -415,15 +415,6 @@ public:
|
|||||||
|
|
||||||
void setMaxJoinedBlockRows(size_t value) { max_joined_block_rows = value; }
|
void setMaxJoinedBlockRows(size_t value) { max_joined_block_rows = value; }
|
||||||
|
|
||||||
TemporaryFileStream* getStreamForCrossJoin()
|
|
||||||
{
|
|
||||||
auto streams = tmp_data->getStreams();
|
|
||||||
assert(streams.size() <= 1);
|
|
||||||
if (streams.empty())
|
|
||||||
return nullptr;
|
|
||||||
return streams[0];
|
|
||||||
}
|
|
||||||
|
|
||||||
private:
|
private:
|
||||||
friend class NotJoinedHash;
|
friend class NotJoinedHash;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user