[Optimize](Runtime Filter) Support merge in runtime filter(#7546) (#7547)

Support merge IN predicate when exist remote target(e.g. shuffle hash join).
Remote the code that IN predicate implicit conversion to Bloom filter then exist  remote target.

Close related #7546
This commit is contained in:
924060929
2022-01-06 19:08:35 +08:00
committed by GitHub
parent e1374d8536
commit 563545475e
14 changed files with 586 additions and 110 deletions

View File

@ -86,7 +86,8 @@ Status HashJoinNode::init(const TPlanNode& tnode, RuntimeState* state) {
for (const auto& filter_desc : _runtime_filter_descs) {
RETURN_IF_ERROR(state->runtime_filter_mgr()->regist_filter(RuntimeFilterRole::PRODUCER,
filter_desc));
filter_desc,
state->query_options()));
}
return Status::OK();