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 88ca4f3e6b [feature](like) make like regexp used as a sql function
(#19755)
add fe42e52851 [pipeline](CTE) Support multi stream data sink in pipeline
(#19519)
No new revisions were added by this update.
Summary of changes:
be/src/exec/data_sink.cpp | 12 ++++
be/src/pipeline/CMakeLists.txt | 4 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 27 +++++--
be/src/pipeline/exec/exchange_sink_operator.h | 7 +-
...nk_operator.h => multi_cast_data_stream_sink.h} | 26 ++++---
.../exec/multi_cast_data_stream_source.cpp | 64 +++++++++++++++++
..._operator.h => multi_cast_data_stream_source.h} | 35 +++++----
be/src/pipeline/exec/multi_cast_data_streamer.cpp | 75 ++++++++++++++++++++
be/src/pipeline/exec/multi_cast_data_streamer.h | 82 ++++++++++++++++++++++
be/src/pipeline/pipeline_fragment_context.cpp | 47 ++++++++++++-
be/src/pipeline/pipeline_fragment_context.h | 5 +-
be/src/vec/sink/multi_cast_data_stream_sink.h | 58 +++++++++++++++
be/src/vec/sink/vdata_stream_sender.cpp | 2 -
13 files changed, 403 insertions(+), 41 deletions(-)
copy be/src/pipeline/exec/{table_sink_operator.h =>
multi_cast_data_stream_sink.h} (57%)
create mode 100644 be/src/pipeline/exec/multi_cast_data_stream_source.cpp
copy be/src/pipeline/exec/{union_source_operator.h =>
multi_cast_data_stream_source.h} (54%)
create mode 100644 be/src/pipeline/exec/multi_cast_data_streamer.cpp
create mode 100644 be/src/pipeline/exec/multi_cast_data_streamer.h
create mode 100644 be/src/vec/sink/multi_cast_data_stream_sink.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
