This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from ded823bf7f7 [opt](recycler) Avoid doing many
`Aws::Internal::GetEC2MetadataClient` http call (#55546)
add 856e4527709 [opt](spill) make spilling operators be blocking mode
(#55556)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.cpp | 9 -
be/src/common/config.h | 2 -
be/src/pipeline/dependency.cpp | 2 +-
be/src/pipeline/dependency.h | 2 +-
.../pipeline/exec/multi_cast_data_stream_sink.cpp | 6 -
be/src/pipeline/exec/multi_cast_data_stream_sink.h | 2 -
.../exec/multi_cast_data_stream_source.cpp | 8 -
.../pipeline/exec/multi_cast_data_stream_source.h | 2 -
be/src/pipeline/exec/multi_cast_data_streamer.cpp | 43 +---
be/src/pipeline/exec/multi_cast_data_streamer.h | 25 +--
be/src/pipeline/exec/operator.h | 12 -
.../exec/partitioned_aggregation_sink_operator.cpp | 245 +++++++++++++++++++--
.../exec/partitioned_aggregation_sink_operator.h | 205 +----------------
.../partitioned_aggregation_source_operator.cpp | 32 +--
.../exec/partitioned_aggregation_source_operator.h | 2 +
.../exec/partitioned_hash_join_probe_operator.cpp | 79 +++----
.../exec/partitioned_hash_join_probe_operator.h | 2 +
.../exec/partitioned_hash_join_sink_operator.cpp | 106 +++++----
.../exec/partitioned_hash_join_sink_operator.h | 6 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 22 +-
be/src/pipeline/exec/spill_sort_sink_operator.h | 2 +
.../pipeline/exec/spill_sort_source_operator.cpp | 35 +--
be/src/pipeline/exec/spill_sort_source_operator.h | 2 +
be/src/pipeline/exec/spill_utils.h | 110 ++-------
be/src/pipeline/pipeline_fragment_context.cpp | 3 +-
be/src/pipeline/pipeline_task.cpp | 87 +++-----
be/src/pipeline/pipeline_task.h | 6 +-
be/src/runtime/query_context.cpp | 3 -
be/src/vec/spill/spill_stream_manager.cpp | 25 ---
be/src/vec/spill/spill_stream_manager.h | 6 -
.../exec/multi_cast_data_streamer_test.cpp | 11 +-
.../partitioned_aggregation_sink_operator_test.cpp | 32 +--
...artitioned_aggregation_source_operator_test.cpp | 29 +--
.../partitioned_aggregation_test_helper.cpp | 5 -
.../partitioned_hash_join_probe_operator_test.cpp | 142 ++----------
.../partitioned_hash_join_sink_operator_test.cpp | 34 +--
.../operator/partitioned_hash_join_test_helper.cpp | 9 +-
.../operator/partitioned_hash_join_test_helper.h | 2 +-
.../operator/spill_sort_sink_operator_test.cpp | 20 +-
.../operator/spill_sort_source_operator_test.cpp | 18 +-
.../operator/spillable_operator_test_helper.cpp | 3 +-
.../operator/spillable_operator_test_helper.h | 16 +-
be/test/pipeline/pipeline_task_test.cpp | 30 ---
43 files changed, 504 insertions(+), 938 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
