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

[runtime filter](profile) add merge time on non-pipeline engine (#22363)

Browse Source
This commit is contained in:
Gabriel
2023-07-31 12:52:42 +08:00
committed by GitHub
parent 7bcf024757
commit b64f62647b
3 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/exprs/runtime_filter.cpp
View File

@ -1810,6 +1810,8 @@ Status IRuntimeFilter::update_filter(const UpdateRuntimeFilterParams* param) {
update_runtime_filter_type_to_profile();
}
this->signal();
_profile->add_info_string("MergeTime", std::to_string(param->request->merge_time()) + " ms");
return Status::OK();
}

1
be/src/runtime/runtime_filter_mgr.cpp
View File

@ -446,6 +446,7 @@ Status RuntimeFilterMergeControllerEntity::merge(const PMergeFilterRequest* requ
rpc_contexts[cur]->request.set_filter_id(request->filter_id());
rpc_contexts[cur]->request.set_is_pipeline(request->has_is_pipeline() &&
request->is_pipeline());
rpc_contexts[cur]->request.set_merge_time(merge_time);
*rpc_contexts[cur]->request.mutable_query_id() = request->query_id();
if (has_attachment) {
rpc_contexts[cur]->cntl.request_attachment().append(request_attachment);

1
gensrc/proto/internal_service.proto
View File

@ -501,6 +501,7 @@ message PPublishFilterRequest {
optional PBloomFilter bloom_filter = 6;
optional PInFilter in_filter = 7;
optional bool is_pipeline = 8;
optional int64 merge_time = 9;
};
message PPublishFilterRequestV2 {