This is an automated email from the ASF dual-hosted git repository.

panxiaolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


    from f74d9abb100 [opt](Nereids) auto fallback when insert unsupport catalog 
(#33353)
     add 1fbed115a95 [Improvement](runtime-filter) support sync join node build 
side's size to init bloom runtime filter (#32180)

No new revisions were added by this update.

Summary of changes:
 be/src/exprs/bloom_filter_func.h                   |   4 +-
 be/src/exprs/runtime_filter.cpp                    | 457 ++++++++++++---------
 be/src/exprs/runtime_filter.h                      |  25 +-
 be/src/exprs/runtime_filter_slots.h                | 167 +++-----
 be/src/pipeline/exec/hashjoin_build_sink.cpp       |  86 ++--
 be/src/pipeline/exec/hashjoin_build_sink.h         |   9 +-
 be/src/pipeline/exec/join_build_sink_operator.cpp  |   3 +-
 be/src/pipeline/exec/join_build_sink_operator.h    |   1 +
 be/src/pipeline/exec/olap_scan_operator.cpp        |   1 -
 be/src/pipeline/pipeline_x/dependency.cpp          |  10 +
 be/src/pipeline/pipeline_x/dependency.h            |  31 +-
 be/src/runtime/fragment_mgr.cpp                    | 159 ++++---
 be/src/runtime/fragment_mgr.h                      |   4 +
 be/src/runtime/runtime_filter_mgr.cpp              |  95 ++++-
 be/src/runtime/runtime_filter_mgr.h                |  32 +-
 be/src/service/backend_options.cpp                 |   1 +
 be/src/service/internal_service.cpp                |  33 +-
 be/src/service/internal_service.h                  |  10 +
 be/src/util/brpc_client_cache.h                    |   4 +
 be/src/vec/exec/join/vhash_join_node.cpp           |   6 +-
 be/src/vec/exec/join/vhash_join_node.h             |  12 +-
 be/src/vec/exec/join/vjoin_node_base.cpp           |   1 +
 be/src/vec/exec/join/vjoin_node_base.h             |   1 +
 .../vec/runtime/shared_hash_table_controller.cpp   |  11 +-
 be/src/vec/runtime/shared_hash_table_controller.h  |  20 +-
 .../org/apache/doris/planner/RuntimeFilter.java    |   4 +
 .../java/org/apache/doris/qe/SessionVariable.java  |   9 +
 gensrc/proto/internal_service.proto                |  26 ++
 gensrc/proto/types.proto                           |   5 +
 gensrc/thrift/PlanNodes.thrift                     |   2 +
 30 files changed, 782 insertions(+), 447 deletions(-)


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to