This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 1fa8720164f [regression-test](merge-on-write) Fix partial update
concurrency conflict case (#25212)
add 7b22ae0c80b [pipelineX](feature) Support set operation operator
(#25251)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/join_probe_operator.h | 2 +
.../pipeline/exec/partition_sort_source_operator.h | 2 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 193 +++++++++++++++++++++
be/src/pipeline/exec/set_probe_sink_operator.h | 102 ++++++++++-
be/src/pipeline/exec/set_sink_operator.cpp | 191 ++++++++++++++++++++
be/src/pipeline/exec/set_sink_operator.h | 76 +++++++-
be/src/pipeline/exec/set_source_operator.cpp | 121 +++++++++++++
be/src/pipeline/exec/set_source_operator.h | 60 ++++++-
be/src/pipeline/exec/union_sink_operator.h | 3 +-
be/src/pipeline/exec/union_source_operator.h | 2 +-
be/src/pipeline/pipeline_x/dependency.h | 169 ++++++++++++++++++
be/src/pipeline/pipeline_x/operator.cpp | 51 +++++-
.../pipeline_x/pipeline_x_fragment_context.cpp | 64 ++++++-
.../pipeline_x/pipeline_x_fragment_context.h | 12 +-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 2 +-
.../vec/common/hash_table/hash_table_set_build.h | 145 ++++++++++++++++
.../vec/common/hash_table/hash_table_set_probe.h | 131 ++++++++++++++
be/src/vec/exec/vset_operation_node.cpp | 135 +-------------
be/src/vec/exec/vset_operation_node.h | 1 -
19 files changed, 1324 insertions(+), 138 deletions(-)
create mode 100644 be/src/vec/common/hash_table/hash_table_set_build.h
create mode 100644 be/src/vec/common/hash_table/hash_table_set_probe.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
