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 a919ef618dd [fix](planner) Fix `select table tablet` not effective
(#25378)
add e8f479882da [pipelineX](local exchange) Add local exchange operator
(#25846)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/exchange_sink_operator.cpp | 10 +-
be/src/pipeline/pipeline_x/dependency.h | 44 +++++++++
.../local_exchange_sink_operator.cpp | 87 ++++++++++++++++++
.../local_exchange/local_exchange_sink_operator.h | 102 +++++++++++++++++++++
.../local_exchange_source_operator.cpp | 52 +++++++++++
.../local_exchange_source_operator.h | 67 ++++++++++++++
be/src/pipeline/pipeline_x/operator.cpp | 6 ++
be/src/pipeline/pipeline_x/operator.h | 9 +-
.../pipeline_x/pipeline_x_fragment_context.cpp | 52 ++++++++++-
.../pipeline_x/pipeline_x_fragment_context.h | 4 +
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 14 ++-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 10 +-
be/src/runtime/runtime_state.h | 3 +
be/src/vec/runtime/partitioner.cpp | 56 +++++++++--
be/src/vec/runtime/partitioner.h | 29 ++++--
be/src/vec/sink/vdata_stream_sender.cpp | 9 +-
be/src/vec/sink/vdata_stream_sender.h | 7 ++
.../java/org/apache/doris/qe/SessionVariable.java | 9 ++
gensrc/thrift/PaloInternalService.thrift | 4 +-
19 files changed, 534 insertions(+), 40 deletions(-)
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.h
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_source_operator.cpp
create mode 100644
be/src/pipeline/pipeline_x/local_exchange/local_exchange_source_operator.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
