This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 1038093c29 [Pipeline](Exec) disable work steal of hash join build
(#15652)
add 9c36278c4a [improvement](pipeline) Support sharing hash table for
broadcast join (#15628)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/CMakeLists.txt | 3 +-
...sink_operator.cpp => empty_source_operator.cpp} | 8 +--
be/src/pipeline/exec/empty_source_operator.h | 62 ++++++++++++++++++++++
be/src/pipeline/exec/hashjoin_build_sink.h | 2 +-
be/src/pipeline/exec/operator.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 9 +++-
be/src/runtime/fragment_mgr.cpp | 36 ++++++++++++-
be/src/runtime/fragment_mgr.h | 7 +--
be/src/vec/exec/join/vhash_join_node.cpp | 9 +---
be/src/vec/exec/join/vhash_join_node.h | 9 ++++
.../vec/runtime/shared_hash_table_controller.cpp | 18 +++++++
be/src/vec/runtime/shared_hash_table_controller.h | 6 +++
.../apache/doris/planner/DistributedPlanner.java | 1 +
.../org/apache/doris/planner/PlanFragment.java | 10 ++++
.../main/java/org/apache/doris/qe/Coordinator.java | 49 ++++++++++++++---
.../java/org/apache/doris/qe/SessionVariable.java | 5 +-
gensrc/thrift/PaloInternalService.thrift | 4 ++
17 files changed, 209 insertions(+), 31 deletions(-)
copy be/src/pipeline/exec/{analytic_sink_operator.cpp =>
empty_source_operator.cpp} (85%)
create mode 100644 be/src/pipeline/exec/empty_source_operator.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
