This is an automated email from the ASF dual-hosted git repository.
zhangstar333 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 0813d701224 [test](beut) add pipeline DistinctStreamingAggOperator
beut (#48805)
add aa28ab984df [refactor](pipeline) refactor local merge sort operator
(#48360)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/dependency.h | 79 +-----
be/src/pipeline/exec/exchange_sink_operator.cpp | 14 -
be/src/pipeline/exec/exchange_sink_operator.h | 2 -
.../exec/local_merge_sort_source_operator.cpp | 159 +++++++++++
.../exec/local_merge_sort_source_operator.h | 117 ++++++++
be/src/pipeline/exec/operator.cpp | 2 +
be/src/pipeline/exec/sort_sink_operator.cpp | 6 +-
be/src/pipeline/exec/sort_source_operator.cpp | 22 +-
be/src/pipeline/exec/sort_source_operator.h | 17 --
.../local_exchange/local_exchange_sink_operator.h | 2 -
.../local_exchange_source_operator.cpp | 28 +-
.../local_exchange_source_operator.h | 7 -
be/src/pipeline/local_exchange/local_exchanger.cpp | 125 +--------
be/src/pipeline/local_exchange/local_exchanger.h | 40 ---
be/src/pipeline/pipeline_fragment_context.cpp | 28 +-
be/src/runtime/runtime_state.h | 5 -
be/src/vec/common/sort/sorter.h | 9 +
be/test/pipeline/local_exchanger_test.cpp | 311 ---------------------
.../local_merge_sort_source_operator_test.cpp | 161 +++++++++++
be/test/pipeline/thrift_builder.h | 4 -
.../mock/mock_sorter.h} | 32 +--
.../java/org/apache/doris/planner/SortNode.java | 20 ++
.../java/org/apache/doris/qe/SessionVariable.java | 5 +-
gensrc/thrift/PaloInternalService.thrift | 2 +-
gensrc/thrift/PlanNodes.thrift | 1 +
25 files changed, 510 insertions(+), 688 deletions(-)
create mode 100644 be/src/pipeline/exec/local_merge_sort_source_operator.cpp
create mode 100644 be/src/pipeline/exec/local_merge_sort_source_operator.h
create mode 100644
be/test/pipeline/operator/local_merge_sort_source_operator_test.cpp
copy be/test/{vec/core/column_vector_test.cpp => testutil/mock/mock_sorter.h}
(63%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
