database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Chore](execute) remove some unused code and adjust check_row_nums #28576

Browse Source
This commit is contained in:
Pxl
2023-12-19 09:55:50 +08:00
committed by GitHub
parent 6503aaf7db
commit 89d728290d
8 changed files with 19 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
be/src/vec/exec/vset_operation_node.cpp
View File

@ -55,10 +55,7 @@ namespace vectorized {
template <bool is_intersect>
VSetOperationNode<is_intersect>::VSetOperationNode(ObjectPool* pool, const TPlanNode& tnode,
const DescriptorTbl& descs)
: ExecNode(pool, tnode, descs),
_valid_element_in_hash_tbl(0),
_mem_used(0),
_build_finished(false) {
: ExecNode(pool, tnode, descs), _valid_element_in_hash_tbl(0), _build_finished(false) {
_hash_table_variants = std::make_unique<HashTableVariants>();
}
@ -229,20 +226,10 @@ Status VSetOperationNode<is_intersect>::sink(RuntimeState* state, Block* block,
SCOPED_TIMER(_exec_timer);
if (block->rows() != 0) {
_mem_used += block->allocated_bytes();
RETURN_IF_ERROR(_mutable_block.merge(*block));
}
if (block->rows() != 0) {
if (_build_block.empty()) {
RETURN_IF_ERROR(_mutable_block.merge(*(block->create_same_struct_block(0, false))));
}
RETURN_IF_ERROR(_mutable_block.merge(*block));
if (_mutable_block.rows() > std::numeric_limits<uint32_t>::max()) {
return Status::NotSupported(
"Hash join do not support build table rows"
" over:" +
std::to_string(std::numeric_limits<uint32_t>::max()));
return Status::NotSupported("set operator do not support build table rows over:" +
std::to_string(std::numeric_limits<uint32_t>::max()));
}
}