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 7c67fa8651 [Bug](pipeline) fix bug of right anti join error result in
pipeline (#15165)
add 494eb895d3 [vectorized](pipeline) support union node operator (#15031)
No new revisions were added by this update.
Summary of changes:
be/src/exec/exec_node.h | 7 +-
be/src/pipeline/CMakeLists.txt | 4 +-
be/src/pipeline/exec/agg_context.cpp | 118 ---------------
be/src/pipeline/exec/agg_context.h | 76 ----------
be/src/pipeline/exec/aggregation_sink_operator.h | 1 -
be/src/pipeline/exec/data_queue.cpp | 162 +++++++++++++++++++++
be/src/pipeline/exec/data_queue.h | 87 +++++++++++
.../exec/streaming_aggregation_sink_operator.cpp | 31 ++--
.../exec/streaming_aggregation_sink_operator.h | 10 +-
.../exec/streaming_aggregation_source_operator.cpp | 20 +--
.../exec/streaming_aggregation_source_operator.h | 10 +-
be/src/pipeline/exec/union_sink_operator.cpp | 85 +++++++++++
...ation_sink_operator.h => union_sink_operator.h} | 41 +++---
be/src/pipeline/exec/union_source_operator.cpp | 80 ++++++++++
...n_source_operator.h => union_source_operator.h} | 27 ++--
be/src/pipeline/pipeline_fragment_context.cpp | 28 +++-
be/src/vec/exec/vunion_node.cpp | 33 ++++-
be/src/vec/exec/vunion_node.h | 24 +--
18 files changed, 551 insertions(+), 293 deletions(-)
delete mode 100644 be/src/pipeline/exec/agg_context.cpp
delete mode 100644 be/src/pipeline/exec/agg_context.h
create mode 100644 be/src/pipeline/exec/data_queue.cpp
create mode 100644 be/src/pipeline/exec/data_queue.h
create mode 100644 be/src/pipeline/exec/union_sink_operator.cpp
copy be/src/pipeline/exec/{streaming_aggregation_sink_operator.h =>
union_sink_operator.h} (52%)
create mode 100644 be/src/pipeline/exec/union_source_operator.cpp
copy be/src/pipeline/exec/{streaming_aggregation_source_operator.h =>
union_source_operator.h} (60%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
