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

[Refactor] Refactor part of RuntimeFilter's code (#6998)

Browse Source 
#6997
This commit is contained in:
Pxl
2021-11-07 17:40:45 +08:00
committed by GitHub
parent 9b1a80114e
commit 29ca77622f
9 changed files with 197 additions and 161 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
be/src/exec/hash_join_node.cpp
View File

@ -242,8 +242,7 @@ Status HashJoinNode::open(RuntimeState* state) {
_runtime_filter_descs);
RETURN_IF_ERROR(thread_status.get_future().get());
RETURN_IF_ERROR(runtime_filter_slots.init(state, _pool, expr_mem_tracker().get(),
_hash_tbl->size()));
RETURN_IF_ERROR(runtime_filter_slots.init(state, _hash_tbl->size()));
{
SCOPED_TIMER(_push_compute_timer);
auto func = [&](TupleRow* row) { runtime_filter_slots.insert(row); };
@ -252,7 +251,7 @@ Status HashJoinNode::open(RuntimeState* state) {
COUNTER_UPDATE(_build_timer, _push_compute_timer->value());
{
SCOPED_TIMER(_push_down_timer);
runtime_filter_slots.publish(this);
runtime_filter_slots.publish();
}
Status open_status = child(0)->open(state);
RETURN_IF_ERROR(open_status);