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 6dbe07bd3b [Enhancement](inverted index) use conjunction query to
accelerate fulltext equal query (#24373)
add d24f3efd4a [pipelineX](profile) Phase 1: refactor pipelineX detailed
profile (#24322)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/aggregation_sink_operator.cpp | 441 +++++++++++----------
be/src/pipeline/exec/aggregation_sink_operator.h | 85 ++--
.../pipeline/exec/aggregation_source_operator.cpp | 336 +++++++++-------
be/src/pipeline/exec/aggregation_source_operator.h | 29 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 6 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 12 +-
be/src/pipeline/exec/analytic_source_operator.h | 2 +-
be/src/pipeline/exec/data_queue.cpp | 27 +-
be/src/pipeline/exec/data_queue.h | 11 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 21 +-
be/src/pipeline/exec/exchange_sink_operator.h | 8 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 33 +-
be/src/pipeline/exec/exchange_source_operator.h | 43 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 2 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 5 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 2 +-
.../exec/nested_loop_join_build_operator.cpp | 2 +-
.../exec/nested_loop_join_probe_operator.cpp | 4 +-
.../exec/nested_loop_join_probe_operator.h | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 8 +-
be/src/pipeline/exec/repeat_operator.cpp | 3 -
be/src/pipeline/exec/result_sink_operator.cpp | 2 -
be/src/pipeline/exec/scan_operator.cpp | 80 ++--
be/src/pipeline/exec/scan_operator.h | 74 +++-
be/src/pipeline/exec/sort_sink_operator.cpp | 3 +-
be/src/pipeline/exec/sort_source_operator.cpp | 6 +-
be/src/pipeline/exec/sort_source_operator.h | 2 +-
.../exec/streaming_aggregation_sink_operator.cpp | 15 +-
.../exec/streaming_aggregation_sink_operator.h | 5 +-
.../exec/streaming_aggregation_source_operator.cpp | 33 +-
.../exec/streaming_aggregation_source_operator.h | 35 +-
be/src/pipeline/exec/union_source_operator.cpp | 3 +-
be/src/pipeline/exec/union_source_operator.h | 5 +-
be/src/pipeline/pipeline.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 13 +-
be/src/pipeline/pipeline_task.h | 6 +-
be/src/pipeline/pipeline_x/dependency.cpp | 31 +-
be/src/pipeline/pipeline_x/dependency.h | 242 ++++++++++-
be/src/pipeline/pipeline_x/operator.cpp | 21 +-
be/src/pipeline/pipeline_x/operator.h | 70 +++-
.../pipeline_x/pipeline_x_fragment_context.cpp | 63 +--
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 82 ++--
be/src/pipeline/pipeline_x/pipeline_x_task.h | 13 +-
be/src/runtime/fragment_mgr.cpp | 21 +-
be/src/runtime/plan_fragment_executor.cpp | 2 +
be/src/runtime/query_context.h | 2 +
be/src/vec/exec/scan/pip_scanner_context.h | 28 +-
be/src/vec/exec/scan/scanner_context.cpp | 19 +-
be/src/vec/exec/scan/scanner_context.h | 14 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 59 +++
be/src/vec/runtime/vdata_stream_recvr.h | 53 +--
.../main/java/org/apache/doris/qe/Coordinator.java | 100 ++++-
gensrc/thrift/FrontendService.thrift | 8 +
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql | 2 +-
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql | 2 +-
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q01.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q02.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q03.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q04.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q05.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q06.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q07.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q08.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q09.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q10.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q11.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q12.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q13.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q14.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q15.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q16.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q17.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q18.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q19.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q20.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q21.sql | 2 +-
.../tpch_unique_sql_zstd_p0/sql/pipelinex_q22.sql | 2 +-
101 files changed, 1517 insertions(+), 773 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
