This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 85a1fbd5d31 [Improve](stats)Use Log4j class library instead of Quartz
(#24732)
add 263506f8ab5 [refactor](pipelineX) add MultiCast operator (#24656)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/exchange_sink_operator.h | 2 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 16 +--
.../exec/multi_cast_data_stream_source.cpp | 43 ++++++
.../pipeline/exec/multi_cast_data_stream_source.h | 150 ++++++++++++++++++++-
be/src/pipeline/exec/union_source_operator.cpp | 85 ++++++++++--
be/src/pipeline/exec/union_source_operator.h | 46 ++++++-
be/src/pipeline/pipeline_x/dependency.h | 26 ++++
be/src/pipeline/pipeline_x/operator.cpp | 70 +++++++++-
be/src/pipeline/pipeline_x/operator.h | 31 ++++-
.../pipeline_x/pipeline_x_fragment_context.cpp | 56 +++++++-
.../pipeline_x/pipeline_x_fragment_context.h | 3 +-
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 31 +++--
be/src/pipeline/pipeline_x/pipeline_x_task.h | 31 +++--
.../data/pipelineX/test_cte_operator.out | 67 +++++++++
.../data/pipelineX/test_union_operator.out | 6 +
...on_operator.groovy => test_cte_operator.groovy} | 70 ++++------
.../suites/pipelineX/test_union_operator.groovy | 31 ++++-
17 files changed, 662 insertions(+), 102 deletions(-)
create mode 100644 regression-test/data/pipelineX/test_cte_operator.out
copy regression-test/suites/pipelineX/{test_union_operator.groovy =>
test_cte_operator.groovy} (60%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
