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 7e17e0d3f7 [fix](Nereids) select outfile column order is wrong (#24595)
add a71d7f2beb [pipelineX](operator) support partition sort operator and
distinct streaming agg operator (#24544)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/aggregation_sink_operator.cpp | 5 +-
be/src/pipeline/exec/aggregation_sink_operator.h | 1 +
be/src/pipeline/exec/aggregation_source_operator.h | 2 +
...istinct_streaming_aggregation_sink_operator.cpp | 166 ++++++++++
.../distinct_streaming_aggregation_sink_operator.h | 50 ++-
...tinct_streaming_aggregation_source_operator.cpp | 48 +++
...istinct_streaming_aggregation_source_operator.h | 17 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 367 +++++++++++++++++++++
.../pipeline/exec/partition_sort_sink_operator.h | 91 ++++-
.../exec/partition_sort_source_operator.cpp | 103 ++++++
.../pipeline/exec/partition_sort_source_operator.h | 53 ++-
be/src/pipeline/exec/sort_source_operator.cpp | 2 +-
.../exec/streaming_aggregation_sink_operator.cpp | 11 +-
.../exec/streaming_aggregation_sink_operator.h | 1 -
be/src/pipeline/pipeline_x/dependency.h | 38 ++-
be/src/pipeline/pipeline_x/operator.cpp | 8 +
.../pipeline_x/pipeline_x_fragment_context.cpp | 39 ++-
.../test_distinct_streaming_agg_operator.out | 69 ++++
.../pipelineX/test_partition_sort_operator.out | 71 ++++
.../test_distinct_streaming_agg_operator.groovy} | 64 ++--
.../pipelineX/test_partition_sort_operator.groovy | 83 +++++
21 files changed, 1240 insertions(+), 49 deletions(-)
create mode 100644 be/src/pipeline/exec/partition_sort_sink_operator.cpp
create mode 100644 be/src/pipeline/exec/partition_sort_source_operator.cpp
create mode 100644
regression-test/data/pipelineX/test_distinct_streaming_agg_operator.out
create mode 100644
regression-test/data/pipelineX/test_partition_sort_operator.out
copy regression-test/suites/{query_p0/stats/query_stats_test.groovy =>
pipelineX/test_distinct_streaming_agg_operator.groovy} (53%)
create mode 100644
regression-test/suites/pipelineX/test_partition_sort_operator.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
