This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 0bdd0079262 [improve](insert-into) add log when instance mark and done
(#29636)
add e556536de1e [Refactor](join) split SetHashTableVariants out from
HashTableVariants (#29519)
add 59d7f64360b [Fix](Nereids) fix pipelineX distribute expr list with
child output expr ids (#29621)
new 767de7afe86 Revert "[feature](pipelineX) control exchange sink by
memory usage (#28814)" (#29652)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/pipeline/exec/aggregation_sink_operator.cpp | 3 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 3 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 7 +-
be/src/pipeline/exec/exchange_sink_operator.h | 7 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 1 -
be/src/pipeline/exec/hashjoin_build_sink.cpp | 29 ++----
be/src/pipeline/exec/hashjoin_build_sink.h | 2 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 16 +--
be/src/pipeline/exec/hashjoin_probe_operator.h | 6 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 71 ++++++-------
be/src/pipeline/exec/set_sink_operator.cpp | 2 +-
be/src/pipeline/exec/set_source_operator.cpp | 25 ++---
be/src/pipeline/exec/sort_sink_operator.cpp | 8 +-
be/src/pipeline/exec/sort_sink_operator.h | 9 +-
be/src/pipeline/pipeline.h | 5 +-
be/src/pipeline/pipeline_x/dependency.h | 3 +-
be/src/vec/common/hash_table/hash_map.h | 2 -
be/src/vec/common/hash_table/hash_map_context.h | 53 +++++-----
.../vec/common/hash_table/hash_table_set_probe.h | 24 ++---
.../vec/exec/join/process_hash_table_probe_impl.h | 94 +++++------------
be/src/vec/exec/join/vhash_join_node.cpp | 34 +++---
be/src/vec/exec/join/vhash_join_node.h | 57 +++-------
be/src/vec/exec/vset_operation_node.cpp | 115 ++++++++++-----------
be/src/vec/exec/vset_operation_node.h | 16 ++-
be/src/vec/runtime/vdata_stream_recvr.cpp | 16 +--
be/src/vec/runtime/vdata_stream_recvr.h | 9 +-
be/src/vec/sink/vdata_stream_sender.h | 5 -
.../glue/translator/PhysicalPlanTranslator.java | 60 ++++++++++-
.../java/org/apache/doris/planner/PlanNode.java | 20 ++++
.../java/org/apache/doris/planner/SortNode.java | 7 ++
gensrc/thrift/PlanNodes.thrift | 4 +
.../test_bucket_hash_local_shuffle.out} | 17 ++-
.../test_bucket_hash_local_shuffle.groovy | 76 ++++++++++++++
33 files changed, 416 insertions(+), 390 deletions(-)
copy
regression-test/data/{nereids_p0/sql_functions/bitmap_functions/test_btimap_count.out
=> pipeline_p0/local_shuffle/test_bucket_hash_local_shuffle.out} (61%)
create mode 100644
regression-test/suites/pipeline_p0/local_shuffle/test_bucket_hash_local_shuffle.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
